Flink:如何使用命令行界面取消正确的 job?


0

我有一个Flink服务器,它运行多个 streaming job。这些 job是使用flink run命令启动的,基本上一直运行到您停止它们为止。现在我想取消一个特定的 job 。当我做flink列表时,我会得到这样的结果:

------------------ Running/Restarting Jobs -------------------
10.12.2015 08:30:37 : d6aeefaa2295ce122b65037805db0891 : Flink Streaming Job (RUNNING)
10.12.2015 08:44:18 : cfe10aca3435730d09691ff644475467 : Flink Streaming Job (RESTARTING)
10.12.2015 08:55:08 : 4ca359e286d4f5b4de62aee76f4c6389 : Flink Streaming Job (RESTARTING)
10.12.2015 08:57:42 : 1b75acb482f2610039ea2211e094b862 : Flink Streaming Job (RESTARTING)
10.12.2015 09:07:22 : 609993523b0214f52fabfdf09baf419d : Flink Streaming Job (RESTARTING)

使用此输出不可能取消正确的 job,因为无法识别哪个 job是哪个 job。所有的 job 都以Flink streaming job 作为他们的名字,所以我不知道该选哪一个。

有没有办法更改flink列表中出现的 job名称?如果没有,是否有方法通过命令行获取有关正在运行的 job的附加信息(例如,它是从哪个JAR文件启动的,它的主类是什么,等等)。如果没有,有没有办法从flink run中获取 jobID,这样我就可以将其存储在某种PID文件中,然后使用该ID取消 job?

1 答案


0

小溪ExecutionEnvironment.execute执行()方法允许您设置 job的名称:

// execute program
env.execute("Streaming data into " + topicName + " topic");

我来回答

写文章

提问题

面试题