Как настроить имя задачи на панели управления apache flink?

Я хочу настроить имя задачи на панели управления apache flink.

Например, если у нас есть карта задач на панели управления с именем MAP, как я могу изменить ее, чтобы добавить конкретное имя?

Большое спасибо.


apache-flink flink-streaming
person FlinkNoob    schedule 01.12.2017    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Операторам можно присвоить имена с помощью метода name(), как показано в следующем примере:

DataStream<X> stream2 = stream
  .map(new MyMapper()).name("MyMapFunction")
  .map(new MyMapper2()).name("MyOtherMapper");
person Fabian Hueske    schedule 01.12.2017
comment
Большое спасибо @Fabian - person FlinkNoob; 01.12.2017