【问题标题】:Flink: How to restart Flink taskmanager on windows?Flink:如何在 Windows 上重启 Flink 任务管理器?
【发布时间】:2020-03-02 20:47:36
【问题描述】:

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

  1. 如何在 Windows 上重启 Flink 任务管理器?我们是否需要安装cygwin并使用它。它会起作用吗?如果 cygwin 工作,请提供继续重新启动任务管理器的步骤。
  2. 有没有更优雅的方式来了解 Windows 上的任务管理器 PID?

【问题讨论】:

  • 好吧,如果您在仪表板上看到检查点已成功完成,这意味着它很可能有效。如果你要测试每一个核心的 flink 功能,那么你还有很长的路要走。
  • 你有答案吗?
  • 你最初是如何启动任务管理器的?为什么不能再这样做?
  • 任务管理器是使用一个名为 start-cluster.bat 的脚本启动的,该脚本会启动包含 taskmanager 的 flink 服务器。但是由于某种原因,如果 flink taskmanager 死了,那么在 linux 上我们可以使用 taskmanager.sh start 重新启动。我不确定在 Windows 上。因此他在上面查询

标签: apache-flink flink-streaming


【解决方案1】:
  1. 如果 Windows 上的任务管理器关闭并且作业管理器正在运行,则只需执行 %FLINK_HOME%\bin\start-cluster.bat 即可启动任务管理器。它只会重新启动任务管理器。

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多