我在两个不同的物理节点上使用具有9个任务管理器的flink集群。当我将jar提交给flink的jobmanager（master）时，jar到底发生了什么。我的意思是，jar是被分发到所有工作节点，还是函数的某些部分被重新应用到所有工作节点？我这样问是因为，当我尝试运行我的应用程序时，它在本地成功运行，但在集群上运行时，在flatmapfunction上给出了一个序列化错误。
ovfsdjhp1#
作业管理器处理应用程序代码，将其拆分为任务和子任务，并将它们发送到任务管理器中的一个或多个（取决于任务并行性）执行槽。来自flink文档：每个worker（taskmanager）是一个jvm进程，可以在不同的线程中执行一个或多个子任务。为了控制一个工人接受多少任务，工人有所谓的任务槽（至少一个）。]
1条答案
按热度按时间ovfsdjhp1#
作业管理器处理应用程序代码，将其拆分为任务和子任务，并将它们发送到任务管理器中的一个或多个（取决于任务并行性）执行槽。来自flink文档：
每个worker（taskmanager）是一个jvm进程，可以在不同的线程中执行一个或多个子任务。为了控制一个工人接受多少任务，工人有所谓的任务槽（至少一个）。]