|
|
|
FLINK-19603
|
FLINK-19582
Introduce shuffle data compression to sort-merge based blocking shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19602
|
FLINK-19582
Introduce new config options to enable sort-merge based blocking shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19601
|
FLINK-19582
Introduce sort-merge based blocking result partition SortMergeResultPartition and the corresponding subpartition reader
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19600
|
FLINK-19582
Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19597
|
FLINK-19582
Introduce SortBuffer and PartitionSortedBuffer for sort-merge based blocking shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|