Найти соответствующий адрес хоста диспетчера задач для запрашиваемого состояния - PullRequest
Новая
       6

Найти соответствующий адрес хоста диспетчера задач для запрашиваемого состояния

0 голосов
/ 17 января 2019

У меня есть 4 менеджера задач и использующий бэкэнд состояния карты (RocksDB). используя QueryableStateClient для запроса состояния. 1. Как получить правильный диспетчер задач для запроса состояния вместо того, чтобы запрашивать весь диспетчер задач. (KvstateLocation) может кто-то предоставить пример кода, который не может найти его в документе.

  1. Как получить шестнадцатеричную строку jobid, используя имя задания.

Flink 1.6.0

1 Ответ

0 голосов
/ 17 января 2019

Найти диспетчер задач для запроса состояния

На самом деле вы можете запросить любой диспетчер задач. Потому что диспетчер задач поможет вам направить ключ к правильному диспетчеру задач через таблицу поиска из менеджера заданий.

Как получить шестнадцатеричную строку jobid, используя имя задания

Flink предоставляет API (/ jobs / Overview) для получения информации о работе.

...