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/23 09:48:06 UTC
[flink] branch master updated (4f93dc5 -> 11663f5)

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 4f93dc5  [FLINK-15803][table] Unify validation for all kinds of UDFs
     add 11663f5  [FLINK-18533][coordination] Tolerate pending deployments being reported

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/executiongraph/Execution.java    |  3 +-
 .../ExecutionDeploymentListener.java               |  6 ++-
 .../executiongraph/ExecutionGraphBuilder.java      |  2 +-
 .../runtime/executiongraph/ExecutionVertex.java    | 14 +++++-
 ...r.java => NoOpExecutionDeploymentListener.java} | 16 ++++--
 .../DefaultExecutionDeploymentReconciler.java      | 21 ++++----
 .../DefaultExecutionDeploymentTracker.java         | 19 ++++++--
 .../jobmaster/ExecutionDeploymentReconciler.java   |  9 ++--
 .../jobmaster/ExecutionDeploymentState.java        | 13 ++---
 .../jobmaster/ExecutionDeploymentTracker.java      | 16 ++++--
 ...eploymentTrackerDeploymentListenerAdapter.java} | 35 +++++++------
 .../apache/flink/runtime/jobmaster/JobMaster.java  |  7 ++-
 .../flink/runtime/scheduler/SchedulerBase.java     |  3 +-
 .../TestingExecutionGraphBuilder.java              |  2 +-
 .../DefaultExecutionDeploymentReconcilerTest.java  | 30 ++++++++++--
 .../DefaultExecutionDeploymentTrackerTest.java     | 46 +++++++++++++----
 ...asterExecutionDeploymentReconciliationTest.java | 57 ++++++++++++++++++++--
 17 files changed, 223 insertions(+), 76 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/{ExecutionDeploymentListener.java => NoOpExecutionDeploymentListener.java} (69%)
 copy flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/JarLocation.java => flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/ExecutionDeploymentState.java (74%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/{ExecutionDeploymentReconciliationHandler.java => ExecutionDeploymentTrackerDeploymentListenerAdapter.java} (53%)