1.6 Apache Flink 基本概念 — 分布式Runtime

分布式运行时环境 1. 任务与算子链 分布式计算中,Flink会将算子(operator) 的子task链式组成tasks,每个task由一个线程执行。把算子链化为tasks是一个非常好的优化:它减少了线程之间的通信和缓冲,而且还能增加吞吐量降低延迟。链化操作的配置详情可参考: chaining docs 下图中dataflow有5个subtasks,因此有5个线程并发进行处理。 2. Job M
相关文章
相关标签/搜索