Flink UI概述

问题描述 投票:0回答:1

我有一个flink UI仪表板,在概述选项卡下,我看到一个包含以下文本的框。只想了解它的含义。

来源:自定义源 - >时间戳/水印 - > FlatMap - > ParDo(SomeMethodNameInJava) - >(ParDo(SinkMetric),ParDo(KafkaWriter))并行:一些数字。

只想了解如何阅读上述信息文本。 (我理解ParDo等的概念)

apache-flink apache-beam flink-streaming
1个回答
1
投票

我猜你正在使用Apache Beam(ParDo)。你究竟想要了解这篇文章到底是什么?您想了解为什么您的Beam计划已转换为此执行计划吗?

通常,本文描述了在任务(此运算符链)中执行的内容。有关Flink运行时的一些上下文信息,您可以阅读此page

© www.soinside.com 2019 - 2024. All rights reserved.