You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/07/08 08:01:51 UTC
[flink] branch master updated (9896c9b -> 2210aff)

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 9896c9b  [FLINK-18514][build] Bump groovy to 2.5.12
     add 2210aff  [FLINK-17075][coordination] Reconcile deployed Executions

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/executiongraph/Execution.java    |   5 +-
 .../ExecutionDeploymentListener.java               |  27 ++
 .../runtime/executiongraph/ExecutionGraph.java     |  16 +-
 .../executiongraph/ExecutionGraphBuilder.java      |  14 +-
 .../ExecutionStateUpdateListener.java              |  27 ++
 .../runtime/executiongraph/ExecutionVertex.java    |  16 +-
 .../DefaultExecutionDeploymentReconciler.java      |  57 +++++
 .../DefaultExecutionDeploymentTracker.java         |  61 +++++
 .../jobmaster/ExecutionDeploymentReconciler.java   |  47 ++++
 .../ExecutionDeploymentReconciliationHandler.java  |  44 ++++
 .../jobmaster/ExecutionDeploymentTracker.java      |  53 ++++
 .../apache/flink/runtime/jobmaster/JobMaster.java  |  61 ++++-
 .../flink/runtime/jobmaster/JobMasterGateway.java  |   6 +-
 .../factories/DefaultJobMasterServiceFactory.java  |   6 +-
 .../flink/runtime/scheduler/DefaultScheduler.java  |   5 +-
 .../runtime/scheduler/DefaultSchedulerFactory.java |   7 +-
 .../flink/runtime/scheduler/SchedulerBase.java     |  26 +-
 .../runtime/scheduler/SchedulerNGFactory.java      |   4 +-
 .../taskexecutor/ExecutionDeploymentReport.java    |  48 ++++
 .../flink/runtime/taskexecutor/TaskExecutor.java   |  22 +-
 .../TaskExecutorToJobManagerHeartbeatPayload.java  |  60 +++++
 .../TestingExecutionGraphBuilder.java              |  16 +-
 .../DefaultExecutionDeploymentReconcilerTest.java  | 139 ++++++++++
 .../DefaultExecutionDeploymentTrackerTest.java     |  88 +++++++
 ...asterExecutionDeploymentReconciliationTest.java | 178 +++++++++++++
 .../jobmaster/JobMasterPartitionReleaseTest.java   |  27 +-
 .../flink/runtime/jobmaster/JobMasterTest.java     |  12 +-
 .../runtime/jobmaster/utils/JobMasterBuilder.java  |  21 +-
 .../jobmaster/utils/TestingJobMasterGateway.java   |  10 +-
 .../utils/TestingJobMasterGatewayBuilder.java      |   6 +-
 ...llocationIdsExposingResourceManagerGateway.java |  48 ++++
 .../ResourceManagerPartitionLifecycleTest.java     |   2 +-
 .../runtime/scheduler/SchedulerTestingUtils.java   |   4 +-
 ...cutorExecutionDeploymentReconciliationTest.java | 279 +++++++++++++++++++++
 34 files changed, 1360 insertions(+), 82 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionDeploymentListener.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionStateUpdateListener.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/DefaultExecutionDeploymentReconciler.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/DefaultExecutionDeploymentTracker.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/ExecutionDeploymentReconciler.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/ExecutionDeploymentReconciliationHandler.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/ExecutionDeploymentTracker.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/ExecutionDeploymentReport.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorToJobManagerHeartbeatPayload.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/DefaultExecutionDeploymentReconcilerTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/DefaultExecutionDeploymentTrackerTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterExecutionDeploymentReconciliationTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/AllocationIdsExposingResourceManagerGateway.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorExecutionDeploymentReconciliationTest.java