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 2022/01/03 20:35:39 UTC

[flink] branch master updated (612fa11 -> 9247bf2)

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

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


    from 612fa11  Revert "[FLINK-25426] Disable UnalignedCheckpointRescaleITCase because it fails regularly"
     add 9247bf2  [FLINK-23946][clients] Dispatcher in application mode should be able to recover after losing and regaining leadership.

No new revisions were added by this update.

Summary of changes:
 .../ApplicationDispatcherBootstrap.java            |  86 +++++-----
 .../ApplicationDispatcherBootstrapITCase.java      | 173 +++++++++++++++++++++
 .../ApplicationDispatcherBootstrapTest.java        | 159 +++++++++++--------
 .../apache/flink/client/testjar/BlockingJob.java   |  90 +++++++++++
 .../flink/client/testjar/MultiExecuteJob.java      |  24 +++
 .../flink/runtime/minicluster/MiniCluster.java     |  13 +-
 .../runtime/jobmaster/JobExecutionITCase.java      |   3 +-
 .../LeaderChangeClusterComponentsTest.java         |  13 +-
 .../runtime/minicluster/TestingMiniCluster.java    |  69 +++++++-
 .../ZooKeeperLeaderElectionITCase.java             |  90 ++++++++---
 10 files changed, 574 insertions(+), 146 deletions(-)
 create mode 100644 flink-clients/src/test/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrapITCase.java
 create mode 100644 flink-clients/src/test/java/org/apache/flink/client/testjar/BlockingJob.java