flink 记录到文件,以查找用户代码不起作用



我是 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。

相关内容

  • 没有找到相关文章

最新更新