【发布时间】:2018-07-08 16:17:12
【问题描述】:
我是 Flink 新手,所以这个问题可能很简单......
Flink 版本为 1.5.0。
我创建了一个示例项目,从 Flink 示例代码中复制了 SocketWindowWordCount。
我的 pom.xml 文件是从官方网站复制的:here
我只是添加了一些简单的 log.info(...) 语句。 无论我在项目资源文件夹中添加 log4j.properties,还是在 flink conf 文件夹中修改 log4j-cli.properties。我添加的日志不会输出到日志文件。
log4j-cli.properties 修改:
log4j.logger.test.flink=INFO, file, console
在 log4j-cli.properties 中添加这一行后,我可以在控制台中看到日志,但在 jobmanager.log 和 taskmanager.log 中仍然没有出现。
我正在使用 flink run 提交:
flink run -m yarn-cluster -yn=2 test.jar
感谢任何帮助。谢谢。
【问题讨论】:
标签: logging apache-flink