Flink运行时之生产端结果分区

生产端结果分区 生产者结果分区是生产端任务所产生的结果。以一个简单的MapReduce程序为例，从静态的角度来看，生产端的算子（Map）跟消费端的算子（Reduce），二者之间交换数据经过中间结果集（IntermediateResult）。形以下图：java 而IntermediateResult只是在静态表述时的一种概念，在运行时，算子会被分布式部署、执行，咱们假设两个算子的并行度都为2，那么对

>>阅读原文<<