【问题标题】:Uploading jar on multiple flink job managers在多个 flink 作业管理器上上传 jar
【发布时间】:2021-12-25 07:48:17
【问题描述】:

所以目前我们在生产环境中使用 HA 模式的 flink 1.12。有 3 名作业经理(1 名领导和 2 名备用)。当我在其中一个工作经理上上传一个 jar 时,不知何故它不会反映在其他工作经理上。有什么方法可以实现将 jar 上传到单个作业管理器的行为也会反映在 HA 中的其他作业管理器中?

因此,我面临的问题是,当 jar 上传到假设“A”作业管理器时,但是在发送作业时使用“B”作业管理器上上传的 jar 提交请求时,出现错误说找不到 jar。

【问题讨论】:

    标签: apache-flink flink-streaming


    【解决方案1】:

    https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/ha/overview/ 上提到State persistence: Persisting state which is required for the successor to resume the job execution (JobGraphs, user code jars, completed checkpoints)

    这意味着 Flink 的 HA 服务也负责 JAR 部分。您是否尝试过关闭活动的 JobManager 会发生什么?

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2023-02-10
      • 1970-01-01
      相关资源
      最近更新 更多