Flink FAQ - Task 之间的数据交换

翻译自原文:https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks Flink中的数据交换基于以下设计原则构建: 数据交换的流控是由接收方启动的,这与原始MapReduce十分相似。 用于数据交换的数据流,即通过物理线路的实际数据传输,是通过IntermediateResult的概念抽象的,并且是可
相关文章
相关标签/搜索