Flink:如何在 windows 上重启 Flink taskmanager?
Flink: How to restart Flink taskmanager on windows?
我的目标是杀死 Flink 任务管理器,然后在 Windows 上重新启动它。这需要在 Flink 中激发错误,以便我可以看到检查点工作。通过查找 PID 与它监听的端口,我设法找到了任务管理器 PID。所以杀死那个 PID 应该杀死 taskmanager 但我无法找到在 windows 上重启 Flink taskmanager 的方法,因为 taskmanager 脚本是一个 shell 脚本。
请帮助我解决以下两个问题。
- 如何在windows重启Flink taskmanager?我们需要安装cygwin并使用它吗?它会工作吗?如果 cygwin 工作,请提供继续重启任务管理器的步骤。
- 是否有更优雅的方式来了解 windows 上的任务管理器 PID?
如果任务管理器在 windows 上关闭并且作业管理器是 运行 那么只需执行 %FLINK_HOME%[=20= 就可以启动任务管理器]。蝙蝠。它只会重新启动任务管理器。
当执行 start-cluster.bat 时,它会打开两个终端(cmd windows) 运行 两个 Java 进程。第二个 window 属于 taskmanager,因此通过在 window 上执行 ctrl+c 可以杀死 taskmanager。还有第一个window属于Jobmanager。
我的目标是杀死 Flink 任务管理器,然后在 Windows 上重新启动它。这需要在 Flink 中激发错误,以便我可以看到检查点工作。通过查找 PID 与它监听的端口,我设法找到了任务管理器 PID。所以杀死那个 PID 应该杀死 taskmanager 但我无法找到在 windows 上重启 Flink taskmanager 的方法,因为 taskmanager 脚本是一个 shell 脚本。 请帮助我解决以下两个问题。
- 如何在windows重启Flink taskmanager?我们需要安装cygwin并使用它吗?它会工作吗?如果 cygwin 工作,请提供继续重启任务管理器的步骤。
- 是否有更优雅的方式来了解 windows 上的任务管理器 PID?
如果任务管理器在 windows 上关闭并且作业管理器是 运行 那么只需执行 %FLINK_HOME%[=20= 就可以启动任务管理器]。蝙蝠。它只会重新启动任务管理器。
当执行 start-cluster.bat 时,它会打开两个终端(cmd windows) 运行 两个 Java 进程。第二个 window 属于 taskmanager,因此通过在 window 上执行 ctrl+c 可以杀死 taskmanager。还有第一个window属于Jobmanager。