|
|
|
FLINK-19286
|
FLINK-16430
Improve pipelined region scheduling performance
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19189
|
FLINK-16430
Enable pipelined scheduling by default
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18355
|
FLINK-16430
Simplify tests of SlotPoolImpl
|
Zhilong Hong
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18114
|
FLINK-16430
Expose more details in logs for debugging bulk slot allocation failures
|
Unassigned
|
Zhu Zhu
|
|
Closed |
Won't Do
|
|
|
|
|
|
|
|
FLINK-18034
|
FLINK-16430
Introduce PreferredLocationsRetriever
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17542
|
FLINK-16430
Unify slot request timeout handling for streaming and batch tasks
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Abandoned
|
|
|
|
|
|
|
|
FLINK-17369
|
FLINK-16430
Migrate RestartPipelinedRegionFailoverStrategyBuildingTest to PipelinedRegionComputeUtilTest
|
Gary Yao
|
Gary Yao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17330
|
FLINK-16430
Avoid scheduling deadlocks caused by cyclic input dependencies between regions
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17181
|
FLINK-16430
Drop generic Types in SchedulingTopology Interface
|
Gary Yao
|
Gary Yao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17180
|
FLINK-16430
Implement PipelinedRegion interface for SchedulingTopology
|
Gary Yao
|
Gary Yao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17047
|
FLINK-16430
Simplify SchedulingStrategy#onPartitionConsumable(...) parameters
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17035
|
FLINK-16430
Replace FailoverTopology with SchedulingTopology
|
Gary Yao
|
Gary Yao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17021
|
FLINK-16430
Blink Planner set GlobalDataExchangeMode
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17020
|
FLINK-16430
Introduce GlobalDataExchangeMode for JobGraph Generation
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17019
|
FLINK-16430
Implement FIFO Physical Slot Assignment in SlotPoolImpl
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17018
|
FLINK-16430
Allocates slots in bulks on pipelined region scheduling
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17017
|
FLINK-16430
Implements bulk allocation for physical slots
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17016
|
FLINK-16430
Integrate pipelined region scheduling
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17014
|
FLINK-16430
Implement PipelinedRegionSchedulingStrategy
|
Zhu Zhu
|
Zhu Zhu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-16960
|
FLINK-16430
Add PipelinedRegion Interface to Topology
|
Gary Yao
|
Gary Yao
|
|
Closed |
Fixed
|
|
|
|
|