我正在将一个自定义flatmap函数应用于flink中的数据流，并希望记录flatmap函数中可能发生的异常。flink作业是在kubernetes上部署和运行的，所以我想我不能只写一些日志文件，然后手动访问它们。我可能只能通过网络浏览器访问flink manager。那么，如何将异常输出到stdout或某个错误/日志流，以便通过web界面查看它们呢？
我正在将一个自定义flatmap函数应用于flink中的数据流，并希望记录flatmap函数中可能发生的异常。flink作业是在kubernetes上部署和运行的，所以我想我不能只写一些日志文件，然后手动访问它们。我可能只能通过网络浏览器访问flink manager。那么，如何将异常输出到stdout或某个错误/日志流，以便通过web界面查看它们呢？
1条答案
按热度按时间vojdkbi01#
如果将flatmap更改为processfunction，则可以使用side输出将每个异常的报告发送到要连接到side输出的任何接收器。