在flink中将作业提交给特定的任务经理



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

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

Flink调度程序不提供这种级别的控制。为了更好地隔离,可以选择按作业或应用程序集群。

Flink中的应用程序部署:当前状态和新的应用程序模式。

最新更新