为可查询状态查找适当的任务管理器主机地址

Question

我有4个任务管理器并使用map状态后端（RocksDB）。使用可查询状态客户端查询状态 。1.如何获得正确的任务管理器来查询状态而不是查询所有的任务管理器。（KvstateLocation ）有人可以提供示例代码无法在文档中找到它。

2. 我们如何使用作业名称获取 jobid 十六进制字符串。

弗林克 1.6.0

Answer 1

查找要查询状态的任务管理器

实际上，您可以查询任何任务管理器。因为任务管理器将帮助您通过作业管理器中的查找表将密钥路由到正确的任务管理器。

我们如何使用作业名称获取 jobid 十六进制字符串

Flink 提供了 API（/jobs/overview）来获取作业信息。