如何在 Kubernetes 上的 Flink (scala) 中记录自定义平面映射函数

Question

我正在将自定义flatMap函数应用于Flink中的DataStream，并希望记录在我的flatMap函数中可能发生的异常。Flink 作业是在 Kubernetes 上部署和运行的，所以我认为我不能只写入一些日志文件，然后手动访问它们。我可能只能通过网络浏览器访问 Flink 管理器。那么，如何将异常输出到 stdout 或某些错误/日志流，以便我可以通过 Web 界面查看它们？

Answer 1

如果将 flatMap 更改为 ProcessFunction，则可以使用端输出将有关每个异常的报告发送到要连接到端输出的任何接收器。