网站后台更新后主页没有变化,wordpress开启多站点后台没显示,f福州网站建设公司,引导企业做网站1、Task
flink中每个算子就是一个Task#xff0c;比如flatMap、map、sum是一个Task。
2、SubTask
算子有几个并行度SubTask的数量就是几#xff0c;比如
3、算子并行度
算子并行度指的是每个算子的并行度#xff0c;可用env.setParallelism(1);设置所有算子的并行度比如flatMap、map、sum是一个Task。
2、SubTask
算子有几个并行度SubTask的数量就是几比如
3、算子并行度
算子并行度指的是每个算子的并行度可用env.setParallelism(1);设置所有算子的并行度也可以对每个算子单独设置通过降数据流划分为多个并行的算子实例SubTask可实现数据的并行处理。
一个Job的并行度是算子并行度的最大值比如一个Job中有map算子并行度是2、filter算子并行度是4则任务并行度就是4。
总结Flink中每一个算子都可以成为一个独立任务(task)。
