|
|
|
FLINK-14289
|
FLINK-10745
Remove Optional fields from RecordWriter relevant classes
|
Zhijiang
|
Zhijiang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-11885
|
FLINK-10745
Introduce RecordWriterBuilder for creating RecordWriter instance
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-11282
|
FLINK-10745
Merge StreamRecordWriter into RecordWriter
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10995
|
FLINK-10745
Copy intermediate serialization results only once for broadcast mode
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10942
|
FLINK-10745
Deduplicate common codes in OutputEmitterTest
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10835
|
FLINK-10745
Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10820
|
FLINK-10745
Simplify the RebalancePartitioner implementation
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10800
|
FLINK-10745
Abstract the StreamPartitionerTest for common codes
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10790
|
FLINK-10745
Refactor all the StreamPartitioner implementations into runtime module
|
Zhijiang
|
Zhijiang
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-10662
|
FLINK-10745
Refactor the ChannelSelector interface for single selected channel
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10537
|
FLINK-10745
Network throughput performance regression after broadcast changes
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-10321
|
FLINK-10745
Make the condition of broadcast partitioner simple
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-9913
|
FLINK-10745
Improve output serialization only once in RecordWriter
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|