Flink中task之间的数据交换机制

Flink中的数据交换构建在以下两条设计原则之上：web 数据交换的控制流（例如，为实例化交换而进行的消息传输）是接收端初始化的，这很是像最初的MapReduce。 数据交换的数据流（例如，在网络上最终传输的数据）被抽象成一个叫作IntermediateResult的概念，它是可插拔的。这意味着系统基于相同的实现逻辑能够既支持流数据，又支持批处理数据的传输。 数据传输包含多个对象，它们是：apac

>>阅读原文<<