一般需要为计算节点配置单独的shaffle本地盘， 同时通过调度算发，让数据密集型作业尽可能分散到不同的节点，确保不出现存储热点节点。 同时也可以增加作业的内存配置和数量，减少spill到本地的文件数量，减少存储开销。...

Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台，它能够基于同一个Flink运行时（Flink Runtime），提供支持流处理和批处理两种类型应用的功能。Flink作为一个针对流数据和批数据的分布式处理引擎，主要用Java代码实现。现有的开源计算方案，把流处理和批处理作为两种...