如何在 Kubernetes 上的 Flink (scala) 中记录自定义 flatMap 函数？

Question

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

Answer 1

如果您将 flatMap 更改为 ProcessFunction，那么您可以使用 side output 将有关每个异常的报告发送到您想要连接到侧输出的任何接收器。