Flink中task之間的數據交換機制

Flink中的數據交換構建在以下兩條設計原則之上：web 數據交換的控制流（例如，爲實例化交換而進行的消息傳輸）是接收端初始化的，這很是像最初的MapReduce。 數據交換的數據流（例如，在網絡上最終傳輸的數據）被抽象成一個叫作IntermediateResult的概念，它是可插拔的。這意味着系統基於相同的實現邏輯能夠既支持流數據，又支持批處理數據的傳輸。 數據傳輸包含多個對象，它們是：apac

>>阅读原文<<