Apache Flink（ジョブに一意のタグを付ける方法）

Question

ジョブを一意の名前でタグ付けすることができますので、後でそれらを停止できますか。私は本当にgrepしてジョブIDを維持したくありません。

一言で言えば、私は配備の一部として仕事を止め、新しいものを配備したいと思っています。あなたはexecute(name: String)コールでそれらを起動したとき

Answer 1

あなたは、ジョブに名前を付けることができ、例えば、

val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment() 

val result: DataStream[] = ???  // your job logic 
result.addSink(new YourSinkFunction) // add a sink 

env.execute("Name of your job")  // execute and assign a name 

REST API of the JobManagerは、ジョブの名前とそののJobIdが含まれるジョブの詳細のリストを提供します。