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/12/06 11:27:05 UTC

[flink] branch master updated (dd6a8f1 -> caf72ab)

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 dd6a8f1  [FLINK-24290][table] Support structured types in JSON functions
     add 6e8efc2  [hotfix][runtime] Remove useless method ExecutionGraph#getTotalNumberOfVertices
     add caf72ab  [FLINK-25031][runtime] Job finishes iff all job vertices finish

No new revisions were added by this update.

Summary of changes:
 .../executiongraph/ArchivedExecutionGraph.java     |  7 +-
 .../executiongraph/DefaultExecutionGraph.java      | 33 +++++----
 .../runtime/executiongraph/ExecutionGraph.java     |  2 -
 .../runtime/executiongraph/ExecutionJobVertex.java | 20 ++++++
 .../runtime/executiongraph/ExecutionVertex.java    |  4 +-
 .../InternalExecutionGraphAccessor.java            |  4 +-
 .../adapter/DefaultExecutionTopology.java          |  4 +-
 .../executiongraph/ExecutionGraphFinishTest.java   | 82 ++++++++++++++++++++++
 .../runtime/scheduler/adaptive/ExecutingTest.java  |  4 +-
 .../adaptive/StateTrackingMockExecutionGraph.java  |  5 --
 10 files changed, 127 insertions(+), 38 deletions(-)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphFinishTest.java