Flink 原理与实现:理解 Flink 中的计算资源

Operator Chains 为了更高效地分布式执行,Flink会尽可能地将operator的subtask链接(chain)在一起形成task。每个task在一个线程中执行。将operators链接成task是非常有效的优化:它能减少线程之间的切换,减少消息的序列化/反序列化,减少数据在缓冲区的交换,减少了延迟的同时提高整体的吞吐量。 我们仍以经典的 WordCount 为例(参考前文Job例
相关文章
相关标签/搜索