我是Flink的新手，所以这个问题可能很简单。。。
flink版本是1.5.0。
我创建了一个示例项目，copy socketwindowwordcount from flink示例代码。
我的pom.xml文件是从官方网站复制的：here
我只是添加了一些smiple log.info（…）语句。无论我在projectresources文件夹中添加log4j.properties，还是在flink conf文件夹中修改log4j-cli.properties。我添加的日志不会输出到日志文件。
log4j-cli.properties修改：
log4j.logger.test.flink=INFO, file, console在log4j-cli.properties中添加这一行之后，我可以在console中看到日志，但仍然没有同时出现在jobmanager.log和taskmanager.log中。
我用flink run提交：
flink run -m yarn-cluster -yn=2 test.jar谢谢你的帮助。谢谢。
1条答案
按热度按时间5tmbdcev1#
我找到了日志位置。
在应用程序主页上：localhost:8080，单击应用程序id进入应用程序概述页面，然后单击日志链接，即可看到jobmananger.err、jobmananger.log、jobmananger.out三个链接。
但我的日志在taskmanager.log中。点击locahost:8042 link 进入节点管理器页面，点击左侧菜单中的“容器列表”，即可在相对容器中找到taskmanager.log。