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