大 UI 概述
Flink UI Overview
我有一个 flink UI 仪表板，在概览选项卡下我看到一个包含以下文本的框。就是想明白什么意思。
来源：自定义来源 -> Timestamps/Watermarks -> FlatMap -> ParDo(SomeMethodNameInJava) -> (ParDo(SinkMetric),ParDo(KafkaWriter)) 并行度：一些数字。
只是想了解如何阅读以上信息文本。 （我理解 ParDo 等的概念）
我猜你正在使用 Apache Beam(ParDo)。关于这篇文章，你到底想了解什么？您想了解为什么您的 Beam 程序会被翻译成这个执行计划吗？
总的来说，本文描述了任务中执行的内容（此运算符链）。有关 Flink 运行时的一些上下文信息，您可以阅读此 page
我有一个 flink UI 仪表板，在概览选项卡下我看到一个包含以下文本的框。就是想明白什么意思。
来源：自定义来源 -> Timestamps/Watermarks -> FlatMap -> ParDo(SomeMethodNameInJava) -> (ParDo(SinkMetric),ParDo(KafkaWriter)) 并行度：一些数字。
只是想了解如何阅读以上信息文本。 （我理解 ParDo 等的概念）
我猜你正在使用 Apache Beam(ParDo)。关于这篇文章，你到底想了解什么？您想了解为什么您的 Beam 程序会被翻译成这个执行计划吗？
总的来说，本文描述了任务中执行的内容（此运算符链）。有关 Flink 运行时的一些上下文信息，您可以阅读此 page