Сопоставить subtask_id с TaskManager в Flink - PullRequest
0 голосов
/ 09 мая 2019

У меня есть оператор с параллелизмом = 256, работающий на 128 менеджерах задач.Каждый раз, когда я получаю ошибку контрольной точки, это происходит в одной и той же подзадаче этого оператора, например, всегда подзадача 129 застревает и блокирует контрольную точку.Я хочу понять, что случилось с этой подзадачей, изучив журналы диспетчера задач, на котором выполняется подзадача 129.Есть ли в Flink способ сопоставить идентификатор подзадачи с соответствующим диспетчером задач?

1 Ответ

0 голосов
/ 09 мая 2019

Файлы taskmanager.log содержат имена развернутых задач, включая их индекс подзадачи.Вы можете просто найти TASK_NAME (129/256) во всех taskmanager.log файлах.

...