apache-flink - 为可查询状态找到合适的任务管理器主机地址

Question

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

2. 我们如何使用 job name 获取 jobid 十六进制字符串。

Flink 1.6.0

标签： apache-flink

Answer 1

找到任务管理器查询状态

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

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

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