我有一个flink UI仪表板,在概述选项卡下,我看到一个包含以下文本的框。只想了解它的含义。
来源:自定义源 - >时间戳/水印 - > FlatMap - > ParDo(SomeMethodNameInJava) - >(ParDo(SinkMetric),ParDo(KafkaWriter))并行:一些数字。
只想了解如何阅读上述信息文本。 (我理解ParDo等的概念)
我猜你正在使用Apache Beam(ParDo)。你究竟想要了解这篇文章到底是什么?您想了解为什么您的Beam计划已转换为此执行计划吗?
通常,本文描述了在任务(此运算符链)中执行的内容。有关Flink运行时的一些上下文信息,您可以阅读此page