Flink: Как перезапустить диспетчер задач Flink на windows? - PullRequest
Новая
       11

Flink: Как перезапустить диспетчер задач Flink на windows?

0 голосов
/ 01 марта 2020

Моя цель - убить диспетчер задач Flink и перезапустить его на Windows. Это необходимо, чтобы вызвать ошибку во Flink, чтобы я мог видеть работу контрольной точки. Мне удалось найти PID диспетчера задач путем поиска PID по порту, который он слушает. Поэтому уничтожение этого PID должно убить TaskManager, но я не могу найти способ перезапустить Flink TaskManager на windows, потому что сценарий TaskManager является сценарием оболочки. Пожалуйста, помогите мне в следующих двух запросах.

  1. Как перезапустить Flink TaskManager на windows? Нужно ли устанавливать Cygwin и использовать его. Это будет работать? Если Cygwin работает, пожалуйста, предоставьте шаги для перезапуска TaskManager.
  2. Есть ли более элегантный способ узнать PID диспетчера задач на windows?

1 Ответ

0 голосов
/ 02 марта 2020

  1. Если диспетчер задач не работает на windows, а менеджер заданий работает, то можно запустить диспетчер задач, просто выполнив% FLINK_HOME% \ bin \ start-cluster.bat. Он просто перезапустит диспетчер задач.

  2. При запуске start-cluster.bat он открывает два терминала (cmd windows), на которых выполняются два процесса Java. Второе окно принадлежит TaskManager, поэтому, нажав Ctrl + c в этом окне, можно убить TaskManager. Также первое окно принадлежит Jobmanager.

...