我有一个 flink 作业,其中我使用 logback 作为我的日志记录框架。除了file
、console
追加器之外,我还使用logstash-logback-appender
将我的日志发送到 logstash 实例。
如果我从 Eclipse 运行 flink 作业,日志将发送到指定的 logstash 服务器。
如果我将应用程序打包为 jar 并在 Eclipse 外部运行它,我可以看到发送到 logstash 的日志。
但是,如果从 flink 仪表板将 flink 应用程序作为作业运行(通过上传与上述相同的 jar),则日志不会发送到 logstash。
我的 flink 设置正在窗口上运行,按照此处的说明在窗口上运行 flink。我开始使用start-cluster.bat
我认为日志配置被忽略了。我已将登录配置放在应用程序中的src/main/resources
。如何让 flink 设置识别回点配置?
我已经尝试了最佳实践中提到的步骤。将log4j
替换为logback
的步骤是针对jobmanager
和taskmanager
日志还是针对应用程序日志?
尝试在 lib/文件夹中添加 logstash-logback-encoder lib 以及 logback jar。