You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/02/26 09:33:33 UTC
[flink] branch master updated (e084dab -> da3b2ad)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e084dab [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks
add 98f9690 [hotfix] Complete AdaptiveScheduler.getTerminationFuture() when reaching Finished state
add aad311b [FLINK-21398][tests] Fix JobMasterTest.testRestoringFromSavepoint and .testRestoringModifiedJobFromSavepoint
add d09d228 [hotfix] Add logging statement when the ExecutionGraph creation failed in the WaitingForResources state
add da3b2ad [hotfix] Add logging to the DefaultAllocatedSlotPool
No new revisions were added by this update.
Summary of changes:
.../slotpool/DefaultAllocatedSlotPool.java | 6 +
.../scheduler/adaptive/AdaptiveScheduler.java | 2 +
.../scheduler/adaptive/WaitingForResources.java | 5 +
.../flink/runtime/jobmaster/JobMasterTest.java | 152 ++-----------------
.../apache/flink/runtime/jobmaster/TestUtils.java | 121 +++++++++++++++
.../slotpool/DefaultDeclarativeSlotPoolTest.java | 41 ++----
.../jobmaster/slotpool/SlotPoolTestUtils.java | 56 +++++++
.../runtime/scheduler/DefaultSchedulerTest.java | 92 ++++++++++++
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 164 +++++++++++++++++----
9 files changed, 441 insertions(+), 198 deletions(-)
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestUtils.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTestUtils.java