如何在Apache Flink仪表板中自定义任务名称

Question

我想自定义Apache Flink仪表板中的任务名称。

例如，当我们在仪表板中有一个任务映射时，名称是映射，我该如何更改它以添加特定名称？

非常感谢。

Answer 1

可以使用name()方法命名运算符，如下所示：

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