Как записать пользовательскую функцию flatMap в Flink (scala) на Kubernetes? - PullRequest
0 голосов
/ 04 апреля 2019

Я применяю пользовательскую функцию flatMap к DataStream во Flink и хочу записать исключения, которые могут возникнуть в моей функции flatMap.Задание Flink развернуто и выполняется в Kubernetes, поэтому я думаю, что не могу просто записать некоторые файлы журнала и получить к ним доступ вручную.Я могу иметь доступ к менеджеру Flink только через веб-браузер.Итак, как я могу вывести исключение в стандартный вывод или какой-нибудь поток ошибок / журналов, чтобы я мог просматривать их через веб-интерфейс?

1 Ответ

0 голосов
/ 05 апреля 2019

Если вы измените flatMap на ProcessFunction, то вы можете использовать боковой вывод для отправки отчета о каждом исключении в любой приемник, который вы хотите подключить к боковому выходу.

...