Apache Flink:已忽略登录配置

Question

我有一个flink工作，其中我使用logback作为我的日志记录框架。除了file、console附加器之外，我还使用logstash-logback-appender将我的日志发送到logstash实例。

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

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

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

我的flink设置是在windows上运行的，按照这里的说明Running flink on windows。我使用start-cluster.bat启动flink

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

我已经尝试过Best practices中提到的步骤。用logback替换log4j的这些步骤是针对jobmanager和taskmanager日志的，还是针对应用程序日志的？

Answer 1

尝试在lib/文件夹中添加logstash- logback -encoder lib和logback jars。