【问题标题】:flink logging to file for user code not workingflink 记录到文件以获取用户代码不起作用
【发布时间】: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


    【解决方案1】:

    我找到了日志位置。

    在yarn应用主页面:localhost:8080,点击应用ID进入应用概览页面,然后点击logs链接,就可以看到jobmananger.err,jobmananger.log,jobmananger.out,3个链接。

    但我的日志在 taskmanager.log 中。点击 locahost:8042 链接进入节点管理器页面,然后点击左侧菜单中的“容器列表”,即可在相关容器中找到 taskmanager.log。

    【讨论】:

      猜你喜欢
      • 2017-06-21
      • 1970-01-01
      • 2022-12-20
      • 2018-12-20
      • 1970-01-01
      • 2019-07-30
      • 1970-01-01
      • 1970-01-01
      • 2013-06-11
      相关资源
      最近更新 更多