Flink task和subTask

概念: Task(任务):Task 是一个阶段多个功能相同 subTask 的集合,类似于 Spark 中的 TaskSet。 subTask(子任务):subTask 是 Flink 中任务最小执行单元,是一个 Java 类的实例,这个 Java 类中有属性和方法,完成具体的计算逻辑。 Operator Chains(算子链):没有 shuffle 的多个算子合并在一个 subTask 中,就形
相关文章
相关标签/搜索