1.1-Flink概念:运行环境

本内容主要参考 flink-runtime 整理 任务和算子链 分布式计算中,Flink 将算子(operator)的 subtask 链接(chain)成 task。 每个 task 由一个线程执行。 把算子链接成 tasks 能够减少线程间切换和缓冲的开销,在降低延迟的同时提高了整体吞吐量。 链接操作的配置详情可参考:chaining docs 下图的 dataflow 由五个 subtask
相关文章
相关标签/搜索