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

Posted to commits@flink.apache.org by tr...@apache.org on 2021/08/23 08:45:58 UTC

[flink] branch release-1.13 updated (669f3b5 -> bffed23)

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

trohrmann pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 669f3b5  [FLINK-23813][connectors/jdbc] Update delete executor in TableJdbcUpsertOutputFormat
     add bffed23  [FLINK-23871][Runtime/Coordination] Dispatcher should handle finishing job exception when recover

No new revisions were added by this update.

Summary of changes:
 .../runtime/jobmanager/OnCompletionActions.java    |  3 ---
 .../jobmaster/DefaultJobMasterServiceProcess.java  |  9 --------
 ...Exception.java => JobAlreadyDoneException.java} | 17 ++++++++++-----
 .../JobMasterServiceLeadershipRunner.java          |  7 +++++-
 .../DefaultJobMasterServiceProcessTest.java        | 14 ------------
 .../JobMasterServiceLeadershipRunnerTest.java      | 25 ++++++++++++++++++++++
 .../runtime/jobmaster/utils/JobMasterBuilder.java  |  5 -----
 7 files changed, 43 insertions(+), 37 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/{JobNotFinishedException.java => JobAlreadyDoneException.java} (56%)