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 a91d951 [FLINK-13118][jdbc] Introduce JDBC table factory and bridge
JDBC table source with streaming table source (#9029)
add 8ce69d9 [hotfix] Remove RpcTimeout annotation from SlotPool
add d73010b [FLINK-13165] Complete slot requests in request order
add 509b92c [hotfix] Introduce SlotPoolPendingRequestFailureTest suite
add 907fec7 [hotfix] Move
SlotPoolImplTest#testSlotRequestCancellationUponFailingRequest to
SlotPoolPendingRequestFailureTest
add d6a0e96 [hotfix] Add
SlotPoolPendingRequestFailureTest#testPendingSlotRequestTimeout
add d30854b [FLINK-13166] Add support for batch slot requests to
SlotPoolImpl
add 6860518 [hotfix] Introduce TestingSlotPoolImpl to expose trigger
timeout methods
add 2be780c [hotfix] Move schedule mode decision to
SchedulingUtils#schedule
add 412f31c [hotfix] Make ExecutionGraph#scheduleMode and
#allowQueuedScheduling final
add 1ab4c16 [hotfix] Remove unused code paths in ExecutionJobVertex
add b8bbd06 [hotfix] Make SlotPoolBuilder a top level class
add b50d4e3 [hotfix] Introduce SlotPoolUtils to share common testing
utilities for the SlotPoolImpl
add 6a72a6a [FLINK-13187] Introduce
ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST
add 7bec861 [hotfix] Remove unused parameters from
Execution#allocateAndAssignSlotForExecution
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/executiongraph/Execution.java | 63 ++---
.../runtime/executiongraph/ExecutionGraph.java | 69 ++---
.../executiongraph/ExecutionGraphBuilder.java | 54 +++-
.../runtime/executiongraph/ExecutionJobVertex.java | 78 ------
.../runtime/executiongraph/ExecutionVertex.java | 10 +-
.../runtime/executiongraph/SchedulingUtils.java | 35 ++-
.../executiongraph/SlotProviderStrategy.java | 126 +++++++++
.../AdaptedRestartPipelinedRegionStrategyNG.java | 19 +-
.../executiongraph/failover/FailoverRegion.java | 3 +-
.../flink/runtime/jobgraph/ScheduleMode.java | 25 +-
.../jobmaster/slotpool/DefaultSlotPoolFactory.java | 14 +-
.../{DualKeyMap.java => DualKeyLinkedMap.java} | 14 +-
.../runtime/jobmaster/slotpool/SchedulerImpl.java | 74 +++--
.../flink/runtime/jobmaster/slotpool/SlotPool.java | 17 +-
.../runtime/jobmaster/slotpool/SlotPoolImpl.java | 303 +++++++++++++++------
.../runtime/jobmaster/slotpool/SlotProvider.java | 17 ++
.../ExecutionGraphCheckpointCoordinatorTest.java | 33 +--
...egionStrategyNGAbortPendingCheckpointsTest.java | 21 +-
...startPipelinedRegionStrategyNGFailoverTest.java | 20 +-
.../ExecutionGraphCoLocationRestartTest.java | 18 +-
.../ExecutionGraphDeploymentTest.java | 110 +++-----
.../executiongraph/ExecutionGraphRestartTest.java | 89 +++---
.../ExecutionGraphSchedulingTest.java | 18 +-
.../executiongraph/ExecutionGraphTestUtils.java | 40 ++-
.../runtime/executiongraph/ExecutionTest.java | 44 ++-
.../executiongraph/ExecutionVertexCancelTest.java | 10 +-
.../ExecutionVertexDeploymentTest.java | 31 ++-
.../ExecutionVertexSchedulingTest.java | 11 +-
.../runtime/executiongraph/FailoverRegionTest.java | 47 +---
.../TestingSlotProviderStrategy.java} | 27 +-
.../jobmanager/scheduler/SchedulerTestBase.java | 4 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 6 +
...alKeyMapTest.java => DualKeyLinkedMapTest.java} | 6 +-
.../slotpool/SlotPoolBatchSlotRequestTest.java | 231 ++++++++++++++++
.../jobmaster/slotpool/SlotPoolBuilder.java | 76 ++++++
.../jobmaster/slotpool/SlotPoolImplTest.java | 130 ++-------
.../slotpool/SlotPoolInteractionsTest.java | 41 ++-
.../SlotPoolPendingRequestFailureTest.java | 185 +++++++++++++
.../slotpool/SlotPoolRequestCompletionTest.java | 130 +++++++++
.../jobmaster/slotpool/SlotPoolResource.java | 2 +-
.../runtime/jobmaster/slotpool/SlotPoolUtils.java | 112 ++++++++
.../jobmaster/slotpool/TestingSlotPoolImpl.java} | 59 ++--
.../LegacySchedulerBatchSchedulingTest.java | 242 ++++++++++++++++
43 files changed, 1884 insertions(+), 780 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SlotProviderStrategy.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{DualKeyMap.java
=> DualKeyLinkedMap.java} (91%)
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/executiongraph/ExecutionAndAllocationFuture.java
=>
test/java/org/apache/flink/runtime/executiongraph/TestingSlotProviderStrategy.java}
(52%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/{DualKeyMapTest.java
=> DualKeyLinkedMapTest.java} (90%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolBatchSlotRequestTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolBuilder.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolPendingRequestFailureTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolRequestCompletionTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolUtils.java
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultSlotPoolFactory.java
=>
test/java/org/apache/flink/runtime/jobmaster/slotpool/TestingSlotPoolImpl.java}
(54%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/LegacySchedulerBatchSchedulingTest.java
