Обзор Flink UI - PullRequest
Новая
       38

Обзор Flink UI

0 голосов
/ 12 сентября 2018

У меня есть панель управления пользовательским интерфейсом Flink, и под вкладкой обзора я вижу поле со следующим текстом. Просто хочу понять, что это значит.

Источник: Пользовательский источник -> Метки времени / водяные знаки -> FlatMap -> ParDo (SomeMethodNameInJava) -> (ParDo (SinkMetric), ParDo (KafkaWriter)) Параллелизм: некоторое число.

Просто хочу понять, как читать приведенный выше текст информации. (Я понимаю концепцию ParDo и т. Д.)

1 Ответ

0 голосов
/ 14 сентября 2018

Полагаю, вы используете Apache Beam (ParDo).Что именно вы хотите понять об этом тексте?Вы хотите понять, почему ваша программа Beam была переведена в этот план выполнения?

В общем, этот текст описывает, что выполняется в задаче (эта цепочка операторов).Некоторую контекстную информацию о среде выполнения Flink вы можете прочитать на этой странице

...