Flink:如何在windows上重新启动Flink任务管理器



我的目标是杀死Flink任务管理器,然后在Windows上重新启动它。这是需要刺激Flink中的错误,以便我可以看到检查点的工作。我已经通过查找它侦听的端口的PID找到了任务管理器PID。因此,杀死该PID应该会杀死taskmanager,但我找不到在windows上重新启动Flink taskmanager的方法,因为taskmanager脚本是shell脚本。请帮我解决以下两个问题。

  1. 如何在windows上重新启动Flink任务管理器?我们需要安装cygwin并使用它吗?它能工作吗?如果cygwin有效,请提供重新启动taskmanager的步骤
  2. 有没有更优雅的方法来了解windows上的任务管理器PID
  1. 如果任务管理器在windows上关闭,并且作业管理器正在运行,则只需执行%FLINK_HOME%\bin\start-cluster.bat即可启动任务管理器。

  2. 当执行start-cluster.bat时,它会打开运行两个Java进程的两个终端(cmd窗口(。第二个窗口属于taskmanager,因此通过在该窗口上执行ctrl+c可以杀死taskmanager。第一个窗口也属于Jobmanager。

最新更新