我的 Flink jar 在 Emr 中运行。我将 logback.xml设置为/mnt/var/flink.log作为它在 Emr 上运行时的路径。我只能看到运行罐子时由 Emr 形成的日志,而看不到我的。请向我建议一种方法,如何获取我在 Emr 中作为 Flink jar 运行的程序中定义的日志。我无法找到适当的解决方案。 我的登录.xml如下所示:
<configuration>
<logger name="org.apache.flink.runtime.jobgraph.JobGraph" level="INFO" additivity="false">
<appender-ref ref="file" />
</logger>
<appender name="file" class="ch.qos.logback.core.FileAppender">
<file>/mnt/var/log/flink.log</file>
<append>false</append>
<encoder>
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{60} %X{sourceThread} - %msg%n</pattern>
</encoder>
</appender>
<root level="INFO">
<appender-ref ref="file"/>
</root>
</configuration>
根据这个SO问题,它可能与FLINK-7990有关。但请注意,您必须将logback.xml
文件 Flink 的conf
目录放在启动 Flink 的系统上。旁注 - 如果你在提问时包括 Flink 的版本,这将非常有帮助,因为它是一个快速移动的目标。