|
|
|
FLINK-12997
|
FLINK-12069
Release partitions for reset vertices
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12993
|
FLINK-12069
Rework forceReleaseOnConsumptionFlag to be JM internal concept
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12883
|
FLINK-12069
Add elaborate partition release logic
|
Gary Yao
|
Gary Yao
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12843
|
FLINK-12069
Refactor the pin logic in ReleaseOnConsumptionResultPartition
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12842
|
FLINK-12069
Fix invalid check released state during ResultPartition#createSubpartitionView
|
Zhijiang
|
Zhijiang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12667
|
FLINK-12069
Add JobID argument to TaskExecutorGateway#releasePartitions
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12666
|
FLINK-12069
Update RM idleness check for TMs to take partitions into account
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Invalid
|
|
|
|
|
|
|
|
FLINK-12647
|
FLINK-12069
Make partition release on consumption optional
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12641
|
FLINK-12069
Release all partitions on job termination
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12616
|
FLINK-12069
Maintain connection between JM<->TM until all partitions have been released
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12615
|
FLINK-12069
Track allocated partitions on the JM
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-12612
|
FLINK-12069
Track stored partitions on the TM
|
Chesnay Schepler
|
Chesnay Schepler
|
|
Closed |
Fixed
|
|
|
|
|