【问题标题】:Submit job to specific task manager in flink在 flink 中将作业提交给特定的任务管理器
【发布时间】:2021-05-22 20:26:09
【问题描述】:

我们有 4 个任务管理器 (tm),每个都运行一个工作线程。 我们尝试在每个任务管理器中使用多个工作线程,但它随机将不同的应用程序提交给一个任务管理器的工作线程。现在的问题是,如果任何应用程序出现故障,它会导致整个 tm 崩溃,从而导致所有其他应用程序崩溃。

所以我可以将我的应用程序提交给特定的 tm,以便该 tm 中的所有工作线程只运行一个应用程序(多线程)。对该应用程序的任何影响都不会影响其他应用程序。

【问题讨论】:

    标签: apache-flink flink-streaming


    【解决方案1】:

    Flink 调度器不提供这种级别的控制。为了更好地隔离,每个作业或应用程序集群是可行的方法。

    Application Deployment in Flink: Current State and the new Application Mode.

    【讨论】:

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