【问题标题】:Flink logs not showing upFlink 日志未显示
【发布时间】:2022-06-10 21:05:29
【问题描述】:

我在 Dev 集群中部署了一个 Flink 应用程序。

  1. 而且我在 Flink 仪表板的任何地方都看不到日志。有人告诉我他们使用了默认的日志记录级别。那可能是什么?

  2. 现在日志没有显示为默认级别,我在哪里重置日志记录级别?

  3. 为了确认,我添加 Sout 语句的方式与添加日志的方式完全相同。它们出现在 Kubernetes 应用程序的任务管理器中。那么为什么不记录呢??

  4. 在代码中,日志是这样添加的:

    log.debug("要显示的日志语句");

    这是最终的日志级别设置吗?我可以在任何地方更改日志级别吗?

  5. 我提到第 4 点,因为 log.debug() 等价于 log.level()。所以如果我在这里设置 level = debug,那么为什么日志语句会显示在 Flink Dashboard 中,当我在开发集群中运行应用程序?

【问题讨论】:

  • 你应该在 kubernetes 日志中找到 Flink 日志——你看过了吗?在最近版本的 Flink 中,我相信即使在 k8s 上运行,日志也会发送到仪表板——你使用的是什么版本的 Flink?
  • 我使用的是 Flink-1.9.1。只有 Sout 语句必须出现在 Kubernetes 中,对吗? log.debug() 语句应该显示在 Flink 仪表板中,对吧?
  • 当前出现在 Flink Dashboard 中的日志,是默认的 Flink 日志,比如作业运行、启动等。不是我在 log.debug() 中添加的。

标签: logging apache-flink


【解决方案1】:

我不知道 Flink 1.9 在 kubernetes 下运行时日志在哪里,但您可能需要登录到每个容器并在日志目录中查找它们。 1.9 中的 kubernetes 集成不是很成熟(或方便)。

从 Flink 1.11 开始,日志将出现在 Flink Web UI 中,从 1.12 开始,它们也默认通过“kubectl logs”提供。请参阅https://issues.apache.org/jira/browse/FLINK-17166 了解更多信息。

【讨论】:

    猜你喜欢
    • 2022-11-11
    • 1970-01-01
    • 2015-10-07
    • 1970-01-01
    • 2017-04-02
    • 2021-05-25
    • 2020-09-14
    • 2019-09-01
    • 2015-04-10
    相关资源
    最近更新 更多