我是 Flink 的新手,所以这个问题可能很简单......
Flink 版本是 1.5.0。
我创建了一个示例项目,从 Flink 示例代码中复制 SocketWindowWordCount。
我的pom.xml文件是从官方网站复制的:这里
我只是添加一些微不足道的 log.info(...(语句。 无论我在项目资源文件夹中添加 log4j.properties,还是在 flink conf 文件夹中修改 log4j-cli.properties。我添加的日志不会输出到日志文件。
log4j-cli.属性修改:
log4j.logger.test.flink=INFO, file, console
在 log4j-cli.properties 中添加此行后,我可以在控制台中看到日志,但仍然没有出现在 jobmanager.log 和 taskmanager.log 中。
我正在使用 flink 运行来提交:
flink run -m yarn-cluster -yn=2 test.jar
感谢任何帮助。谢谢。
我找到了日志位置。
在纱线应用主页:localhost:8080,点击应用ID进入应用概览页面,然后点击日志链接,只能看到jobmananger.err,jobmananger.log,jobmananger.out,3个链接。
但是我的日志在任务管理器中.log。点击locahost:8042链接进入节点管理器页面,然后点击左侧菜单的"容器列表",即可在相对容器中找到任务管理器.log。