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 f892879  fixup! [FLINK-23189][checkpoint] Count and fail the task in 
case of IOExceptions in CheckpointCoordinator
     add e459aef  [hotfix][tests] Add ZooKeeperResource.stop()
     add 71caf5e  [hotfix][tests] Rename 
ZooKeeperLeaderElectionConnectionHandlingTest to 
ZooKeeperLeaderRetrievalConnectionHandlingTest
     add 9635083  [FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper 
connections
     add 82b4c24  [FLINK-10052][tests] Extend test suite for handling of 
ZooKeeper connections
     add 6b8cd68  [hotfix][tests] Replace Junit assertThat with Hamcrest's in 
ZooKeeperLeaderRetrievalConnectionHandlingTest
     add d18eb5c  [FLINK-10052][docs] Update ZooKeeper HA services 
documentation to include support for tolerating suspended connections
     add b2167c4  [hotfix][tests] Clean up 
ZooKeeperLeaderRetrievalConnectionHandlingTest

No new revisions were added by this update.

Summary of changes:
 docs/content.zh/docs/deployment/ha/zookeeper_ha.md |  13 +
 docs/content/docs/deployment/ha/zookeeper_ha.md    |  13 +
 .../expert_high_availability_zk_section.html       |   6 +
 .../generated/high_availability_configuration.html |   6 +
 .../configuration/HighAvailabilityOptions.java     |  18 +
 .../HighAvailabilityServicesUtils.java             |   2 +-
 .../zookeeper/ZooKeeperClientHAServices.java       |   9 +-
 .../zookeeper/ZooKeeperHaServices.java             |   2 +-
 .../ZooKeeperLeaderElectionDriver.java             |   5 +-
 .../ZooKeeperLeaderRetrievalDriver.java            |  32 +-
 .../ZooKeeperLeaderRetrievalDriverFactory.java     |  16 +-
 .../apache/flink/runtime/util/ZooKeeperUtils.java  |  42 ++-
 ...KeeperLeaderElectionConnectionHandlingTest.java | 409 ++++++++-------------
 ...eperLeaderRetrievalConnectionHandlingTest.java} |  92 ++++-
 .../flink/runtime/zookeeper/ZooKeeperResource.java |   5 +
 15 files changed, 379 insertions(+), 291 deletions(-)
 copy 
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/{ZooKeeperLeaderElectionConnectionHandlingTest.java
 => ZooKeeperLeaderRetrievalConnectionHandlingTest.java} (77%)

Reply via email to