95-235-050-源碼-task-Flink task之間的數據交換

1.世界 2.概述 Flink中的數據交換是圍繞着下面的原則設計的： 數據交換的控制流（即，爲了啓動交換而傳遞的消息）是由接收者發起的，就像原始的MapReduce一樣。 用於數據交換的數據流，即通過電纜的實際數據傳輸，被抽象爲了IntermediateResult，並且是可插拔的。 這意味着系統可以使用同一實現同時支持流數據傳輸和批處理數據傳輸。 數據交換也涉及到了一些角色，包括： JobMan

>>阅读原文<<