0

我有一个 flink 工作,我使用 logback 作为我的日志框架。除了file, consoleappenders 之外,我还使用logstash-logback-appender将我的日志发送到 logstash 实例。

如果我从 Eclipse 运行 flink 作业,日志将发送到指定的 logstash 服务器。

如果我将应用程序打包为 jar 并在 Eclipse 外部运行,我可以看到日志被发送到 logstash。

但是,如果从 flink 仪表板将 flink 应用程序作为作业运行(通过上传与上述相同的 jar),则日志不会发送到 logstash。

我的 flink 设置正在 windows 上按照Running flink on windows的说明运行。我开始使用 flinkstart-cluster.bat

我认为 logback 配置被忽略了。我已将 logback 配置放在src/main/resources我的应用程序中。如何获得 flink setup 识别的 logback 配置?

我已经尝试过最佳实践中提到的步骤。此替换步骤log4jlogback针对jobmanager&taskmanager日志还是针对应用程序日志?

4

1 回答 1

0

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

于 2019-11-05T19:24:53.007 回答