补充一个细节:
当我把shuffle加到cal和sort中间时, source-->cal-- (rebalance)->sort--->SinkConversionToRow--->sink shuffle的数据传输IO速度是3G/s,需要传输的文件大小是370G。 当我把shuffle加到SinkConversionToRow和sink中间时, source-->cal-- ->sort--->SinkConversionToRow--(rebalance)-->sink shuffle的数据传输IO速度是0.1G/s,需要传输的文件大小是250G。 文件大小也是有区别的。 -- Sent from: http://apache-flink.147419.n8.nabble.com/
