【发布时间】:2019-11-06 03:24:53
【问题描述】:
我有一个 flink 作业,我使用 logback 作为我的日志框架。除了file、console 附加程序之外,我还使用logstash-logback-appender 将我的日志发送到logstash 实例。
如果我从 Eclipse 运行 flink 作业,日志将发送到指定的 logstash 服务器。
如果我将应用程序打包为 jar 并在 Eclipse 外部运行,我可以看到正在发送到 logstash 的日志。
但是,如果从 flink 仪表板将 flink 应用程序作为作业运行(通过上传与上述相同的 jar),则日志不会发送到 logstash。
按照Running flink on windows 的说明,我的 flink 设置正在 Windows 上运行。我使用start-cluster.bat开始flink
我认为 logback 配置被忽略了。我已在我的应用程序中将 logback 配置放置在 src/main/resources。如何获得 flink setup 识别的 logback 配置?
我已经尝试了Best practices 中提到的步骤。将log4j 替换为logback 的步骤是针对jobmanager 和taskmanager 日志还是针对应用程序日志?
【问题讨论】:
-
我也有类似的情况,请问您是如何解决这个问题的?
标签: logback apache-flink flink-streaming logstash-logback-encoder