当前位置: 首页 > 知识库问答 >
问题:

Flink:如何重新启动Flink taskManager上的窗口?

鲍飞星
2023-03-14

我的目标是杀死Flink任务管理器,然后在Windows上重新启动它。这是刺激Flink中的错误所必需的,这样我就可以看到检查点的工作。我已经设法找到了任务管理器PID通过查找PID对它侦听的端口。所以杀死PID应该杀死taskManager,但是我找不到在windows上重启Flink taskManager的方法,因为taskManager脚本是一个外壳脚本。请帮助我在以下两个问题。

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

共有1个答案

庾和昶
2023-03-14

>

  • 如果windows上的任务管理器已关闭且作业管理器正在运行,则只需执行%FLINK\u HOME%\bin\start cluster即可启动任务管理器。球棒它将重新启动taskmanager。

    当start-cluster.bat执行时,它打开两个终端(cmd窗口),运行两个Java进程。第二个窗口属于taskManager,所以通过在该窗口上执行ctrl c,可以杀死taskManager。第一个窗口也属于JobManager。

  •  类似资料:
    • 有人能给这点启示吗?

    • 在Flink有可能吗?如果是的话,那该怎么做呢?

    • 问题内容: 我编写了一个任务,通过套接字发送某些TCP消息。我有一个包含一堆消息和一些时间戳的文件,因此我将该任务编程为TimerTask,并使用带有第一个消息时间戳的Timer对其进行了调度。 完成后,任务运行方法结束,但其关联的线程仍然存在,不会被取消。如果我尝试使用新的时间重新安排任务,则会收到异常消息,通知我无法重新安排已安排的任务或取消的任务。 在重新计划之前,我也尝试过使用cancel

    • 问题内容: 我试图编写一个文件监视器,它将检查文件是否添加了新行,该监视器实际上是一个线程,它将始终由randomaccessfile读取该行。 这是监视器的核心代码: 这是一些帮助类: 这是调用监视器的示例: 现在,我的问题是,如果我仅调用以下代码,代码就可以很好地工作: 这将监视文件的行追加,并通知侦听器。 但是,当我致电: 这意味着我想监视另一个文件而不是之前。 因此,在Monitor中,我

    • 我通过jenkins在我的windows 10机器上运行jenkins。通过从cmd运行以下命令进行战争 java-jarjenkins.war--httpPost=8047 当我尝试通过UI重新启动jenkins时,我无法执行此操作,出现异常“jenkins无法按当前配置重新启动自身” 这是我迄今为止通过重新启动尝试的命令。 http://localhost:8090/restart我还尝试了另

    • 问题内容: 我有一个静态课程(Foo)和一个主课程(Main) 参见Main.java: 参见Foo.java: 有什么方法可以重新启动或重置静态类? 注意:我需要这样做是因为我正在用jUnit测试静态类,并且需要在第二次测试之前清除参数。 编辑 几乎解决方案: 使用StanMax答案,我可以这样做: Main.java MyClassLoader.java Foo.java 输出值 问题:如果我