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는 작업의 이름과 작업 ID를 포함하는 작업 세부 목록을 제공합니다.