|
|
|
FLINK-30670
|
FLINK-29663
Ignore broadcast bytes when computing parallelism and input infos for adaptive batch scheduler
|
Lijie Wang
|
Lijie Wang
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-30631
|
FLINK-29663
Limit the max number of subpartitons consumed by each downstream task
|
Lijie Wang
|
Lijie Wang
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-30604
|
FLINK-29663
Remove the limitation that parallelism decided by adaptive batch scheduler is always a power of two
|
Lijie Wang
|
Lijie Wang
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-29666
|
FLINK-29663
Let adaptive batch scheduler divide subpartition range according to amount of data
|
Lijie Wang
|
Lijie Wang
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-29665
|
FLINK-29663
Support flexible subpartition range divisions
|
Lijie Wang
|
Lijie Wang
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-29664
|
FLINK-29663
Collect subpartition sizes of BLOCKING result partitions
|
Lijie Wang
|
Lijie Wang
|
|
Closed |
Done
|
|
|
|
|