apache flink 대시 보드에서 작업 이름을 사용자 정의하는 방법은 무엇입니까?

Question

apache flink 대시 보드에서 작업 이름을 사용자 정의하고 싶습니다.

예를 들어 대시 보드에 작업 맵이있는 경우 이름은 MAP입니다. 특정 이름을 추가하려면 어떻게 변경합니까?

고마워요. 다음 예와 같이

Answer 1

운영자는 name() 방법을 사용하여 지정 될 수

DataStream<X> stream2 = stream 
    .map(new MyMapper()).name("MyMapFunction") 
    .map(new MyMapper2()).name("MyOtherMapper");