Apache Flink（如何唯一标记作业）

Question

是否可以使用唯一名称标记作业，以便我可以在以后停止它们？。我真的不想 grep 和持久化作业 ID。

简而言之，作为部署的一部分，我想停止一项工作并部署新的工作。

Answer 1

您可以在execute(name: String)呼叫中启动作业时命名作业，例如，

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

JobManager的REST API提供了一个作业详细信息列表，其中包括作业名称及其 JobId。