无法在 Flink Native Kubernetes 中更新 logback 配置

Question

我已经成功创建了一个 Flink Native Kubernetes (1.14.2) 集群。我正在尝试更新我使用 Flink Native Kubernetes 公开的 configmap 的 logback 配置。 Flink Native Kubernetes 在集群启动时创建此 configmap，并在集群停止时将其删除，此行为符合官方文档。

我更新了同样成功的 logback configmap，这个过程甚至更新了作业管理器和任务管理器中的实际 logback 文件（conf 文件夹）。但是 Flink 没有加载（热加载）这个 logback 配置。

我还想确保即使在集群重新启动期间也会保留 logback configmap 配置。但是每次集群启动时，Flink Native Kubernetes 都会重新创建 configmap。

我在这里缺少什么？如何使更新后的 logback 配置生效？

Answer 1

你可以参考https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/advanced/logging/中的“配置logback”

Answer 2

解决方案

要启动 Flink Native Kubernetes 集群，我们将调用 kubernetes-session.sh。我们只需要在调用 kubernetes-session.sh 之前更新本地的 conf 文件夹。以下是根据我们的要求更新的文件。

1. flink-conf.yaml
2. 记录器
   • logback-console.xml（使用 logback 时）
   • log4j-console.properties（使用 log4j 时）

它是如何工作的

基本上，本地 conf 文件夹中的文件用于在 Kubernetes 中创建 configmap，其中包含上述 3 个文件，无论您使用 logback 还是 log4j。当容器启动时，configmap 中的内容会被复制到容器（jobmanager 和 taskmanager）中。

Reference

感谢在 flink 邮件列表中给出解决方案的 Sharon Xie。