|
|
|
FLINK-22307
|
FLINK-19614
Increase the default value of data writing cache size (not configurable) for sort-merge blocking shuffle
|
Unassigned
|
Yingjie Cao
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-22127
|
FLINK-19614
Enrich error message of read buffer request timeout exception
|
Unassigned
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21951
|
FLINK-19614
Fix wrong if condition in BufferReaderWriterUtil#writeBuffers
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21850
|
FLINK-19614
Improve document and config description of sort-merge blocking shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21778
|
FLINK-19614
Use heap memory instead of direct memory as index entry cache for sort-merge shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21777
|
FLINK-19614
Replace the 4M data writing cache of sort-merge shuffle with writev system call
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20758
|
FLINK-19614
Use region file mechanism for shuffle data reading before we switch to managed memory
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-20757
|
FLINK-19614
Optimize data broadcast for sort-merge shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20740
|
FLINK-19614
Use managed memory to avoid direct memory OOM error for sort-merge shuffle (introduce a separated buffer pool)
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19938
|
FLINK-19614
Implement shuffle data read scheduling for sort-merge blocking shuffle
|
Yingjie Cao
|
Yingjie Cao
|
|
Closed |
Fixed
|
|
|
|
|