理解Flink并行处理

理解Flink并行处理 ··························· 分布式计算中,Flink 将算子(operator)的 subtask *链接(chain)*成 task【类似于Spark中的Stage阶段】。每个 task 由一个线程执行。把算子链接成 tasks 能够减少线程间切换和缓冲的开销,在降低延迟的同时提高了整体吞吐量。 当前的flink应用由3个Task,5个SubT
相关文章
相关标签/搜索