This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f85dfbb [FLINK-18290][checkpointing] Don't System.exit on
CheckpointCoordinator failure if it is shut down
add 025f457 [FLINK-17019][runtime] All pending requests removal goes to
SlotPool#removePendingRequest() for centrally management
add 1b34f18 [FLINK-17019][runtime] Fulfill slot requests in request order
add 995e686 [hotfix][runtime] Make DualKeyLinkedMap package private
add b8698c0 [FLINK-17019][runtime] Make clear the iteration order
contract of DualKeyLinkedMap
add b5e3c92 [FLINK-17019][runtime] Enable DualKeyLinkedMap for querying
primary/secondary key with a given secondary/primary key
add 01360fe [FLINK-17019][runtime] Change primary key re-insertion in
DualKeyLinkedMap to not affect the insertion order
add df9a882 [FLINK-17019][runtime] Remap orphaned slot allocation to
pending slot request which just lost its allocation
No new revisions were added by this update.
Summary of changes:
.../jobmaster/slotpool/DualKeyLinkedMap.java | 79 +++++++++++-----
.../runtime/jobmaster/slotpool/SlotPoolImpl.java | 102 +++++++++++++--------
.../jobmaster/slotpool/DualKeyLinkedMapTest.java | 42 +++++++--
.../jobmaster/slotpool/SlotPoolImplTest.java | 83 ++++++++++++++++-
.../SlotPoolPendingRequestFailureTest.java | 40 ++++++++
.../slotpool/SlotPoolRequestCompletionTest.java | 34 +++++--
6 files changed, 306 insertions(+), 74 deletions(-)
