Apache Flink:忽略了登录配置



我有一个 flink 作业,其中我使用 logback 作为我的日志记录框架。除了fileconsole追加器之外,我还使用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的步骤是针对jobmanagertaskmanager日志还是针对应用程序日志?

尝试在 lib/文件夹中添加 logstash-logback-encoder lib 以及 logback jar。

相关内容

  • 没有找到相关文章

最新更新