[flink] branch master updated (ef0dc509 -> 4bc56a4)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from ef0dc509 [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert
     add 2352586  [FLINK-14532][coordination] Rename PartitionTracker
     add 4bc56a4  [FLINK-14532][coordination] Split PartitionTracker

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/executiongraph/Execution.java    |   6 +-
 .../runtime/executiongraph/ExecutionGraph.java     |  12 +--
 .../executiongraph/ExecutionGraphBuilder.java      |   6 +-
 ...ionGraphResultPartitionAvailabilityChecker.java |   6 +-
 .../partition/AbstractPartitionTracker.java        | 117 +++++++++++++++++++++
 ...Tracker.java => JobMasterPartitionTracker.java} |  22 +---
 ...mpl.java => JobMasterPartitionTrackerImpl.java} |  95 ++++-------------
 .../io/network/partition/PartitionTracker.java     |  39 ++-----
 .../network/partition/PartitionTrackerEntry.java}  |  33 +++---
 .../network/partition/PartitionTrackerFactory.java |   4 +-
 .../apache/flink/runtime/jobmaster/JobMaster.java  |   4 +-
 .../factories/DefaultJobMasterServiceFactory.java  |   4 +-
 .../flink/runtime/scheduler/DefaultScheduler.java  |   4 +-
 .../runtime/scheduler/DefaultSchedulerFactory.java |   4 +-
 .../flink/runtime/scheduler/LegacyScheduler.java   |   4 +-
 .../runtime/scheduler/LegacySchedulerFactory.java  |   4 +-
 .../flink/runtime/scheduler/SchedulerBase.java     |   8 +-
 .../runtime/scheduler/SchedulerNGFactory.java      |   4 +-
 .../CheckpointSettingsSerializableTest.java        |   4 +-
 ...inedRegionStrategyNGConcurrentFailoverTest.java |   6 +-
 ...startPipelinedRegionStrategyNGFailoverTest.java |   6 +-
 .../ExecutionGraphDeploymentTest.java              |   4 +-
 .../ExecutionGraphPartitionReleaseTest.java        |  10 +-
 .../ExecutionGraphRescalingTest.java               |  10 +-
 ...raphResultPartitionAvailabilityCheckerTest.java |   4 +-
 .../ExecutionGraphSchedulingTest.java              |   4 +-
 .../executiongraph/ExecutionGraphTestUtils.java    |   8 +-
 .../ExecutionPartitionLifecycleTest.java           |  12 +--
 .../ExecutionVertexLocalityTest.java               |   4 +-
 .../executiongraph/ExecutionVertexTest.java        |   4 +-
 .../partition/AbstractPartitionTrackerTest.java    | 101 ++++++++++++++++++
 ...java => JobMasterPartitionTrackerImplTest.java} |  91 +++-------------
 ...ker.java => NoOpJobMasterPartitionTracker.java} |  11 +-
 ....java => TestingJobMasterPartitionTracker.java} |  11 +-
 .../flink/runtime/jobmaster/JobMasterTest.java     |  16 +--
 .../runtime/scheduler/DefaultSchedulerTest.java    |   4 +-
 .../LegacySchedulerBatchSchedulingTest.java        |   4 +-
 37 files changed, 381 insertions(+), 309 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/AbstractPartitionTracker.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/{PartitionTracker.java => JobMasterPartitionTracker.java} (74%)
 rename flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/{PartitionTrackerImpl.java => JobMasterPartitionTrackerImpl.java} (58%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/{taskexecutor/TaskExecutorHeartbeatPayload.java => io/network/partition/PartitionTrackerEntry.java} (57%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/AbstractPartitionTrackerTest.java
 rename flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/{PartitionTrackerImplTest.java => JobMasterPartitionTrackerImplTest.java} (70%)
 rename flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/{NoOpPartitionTracker.java => NoOpJobMasterPartitionTracker.java} (76%)
 rename flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/{TestingPartitionTracker.java => TestingJobMasterPartitionTracker.java} (88%)