You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2021/11/04 11:35:12 UTC
[flink] branch master updated (d0c00ac -> 4d9de6c)
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 d0c00ac [FLINK-24609][akka][build] Use same Scala properties as root pom
add 44fc8cb [hotfix][runtime] Refactor testing methods out from SlotProfile into SlotProfileTestingUtils
add fcca10c [hotfix][runtime] Rename `previousExecutionGraphAllocations` in SlotProfile to `reservedAllocations` to avoid confusion
add cdeed7d [hotfix][tests] Factor PerJobMiniClusterFactoryTest#MyCancellableInvokable out to be a standalone test class in flink-runtime
add 4618b6a [FLINK-19142][runtime] Use LocationPreferenceSlotSelectionStrategy for batch jobs even if local recovery is enabled
add 4d9de6c [FLINK-19142][runtime] Fix slot hijacking after task failover
No new revisions were added by this update.
Summary of changes:
.../program/PerJobMiniClusterFactoryTest.java | 33 +---
.../clusterframework/types/SlotProfile.java | 62 ++------
.../PreviousAllocationSlotSelectionStrategy.java | 3 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 49 ++++++
.../scheduler/DefaultSchedulerComponents.java | 31 +++-
.../scheduler/ExecutionSlotAllocationContext.java | 11 ++
.../MergingSharedSlotProfileRetrieverFactory.java | 31 ++--
.../SlotSharingExecutionSlotAllocatorFactory.java | 4 +-
...ocationPreferenceSlotSelectionStrategyTest.java | 15 +-
.../types/SlotProfileTestingUtils.java | 61 +++++++
...lSlotProviderImplWithSpreadOutStrategyTest.java | 4 +-
.../slotpool/PhysicalSlotProviderResource.java | 6 +-
.../DefaultSchedulerComponentsFactoryTest.java | 30 ++++
.../MergingSharedSlotProfileRetrieverTest.java | 41 ++++-
.../SlotSharingExecutionSlotAllocatorTest.java | 3 +-
.../TestExecutionSlotAllocatorFactory.java | 7 +
.../WaitingCancelableInvokable.java} | 30 ++--
.../DefaultSchedulerLocalRecoveryITCase.java | 177 +++++++++++++++++++++
18 files changed, 461 insertions(+), 137 deletions(-)
create mode 100755 flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/types/SlotProfileTestingUtils.java
copy flink-runtime/src/test/java/org/apache/flink/runtime/{testtasks/BlockingNoOpInvokable.java => testutils/WaitingCancelableInvokable.java} (62%)
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java