You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ga...@apache.org on 2022/07/14 04:05:07 UTC

[flink] branch master updated (21242800842 -> ed236ee19d7)

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

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


    from 21242800842 [FLINK-28486][docs-zh] Flink FileSystem SQL Connector Doc is not right
     add ed236ee19d7 [FLINK-28457][runtime] Introduce JobStatusHook to allow users to listen for the job status changes

No new revisions were added by this update.

Summary of changes:
 .../executiongraph/DefaultExecutionGraph.java      | 35 +++++++++-
 .../DefaultExecutionGraphBuilder.java              |  3 +-
 .../{JobStatusListener.java => JobStatusHook.java} | 41 ++++++++---
 .../apache/flink/runtime/jobgraph/JobGraph.java    | 13 ++++
 .../executiongraph/TestingJobStatusHook.java       | 69 +++++++++++++++++++
 .../runtime/scheduler/DefaultSchedulerTest.java    | 80 ++++++++++++++++++++++
 .../flink/streaming/api/graph/StreamGraph.java     | 15 ++++
 .../api/graph/StreamingJobGraphGenerator.java      |  4 ++
 8 files changed, 247 insertions(+), 13 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/{JobStatusListener.java => JobStatusHook.java} (51%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingJobStatusHook.java