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/09/03 13:12:51 UTC
[flink] branch release-1.14 updated (7b1c5a6 -> 94387a4)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7b1c5a6 [FLINK-21090] Minor code improvements
add 68bfd20 [FLINK-24056][ha] Remove unused ZooKeeperUtilityFactory
add 7ce4435 [FLINK-24060][Tests]Move ZooKeeperUtilTest to right class
add 94387a4 [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client
No new revisions were added by this update.
Summary of changes:
.../client/program/rest/RestClusterClient.java | 23 +++--
.../kubernetes/KubernetesClusterDescriptor.java | 4 +-
.../runtime/entrypoint/ClusterEntrypoint.java | 6 +-
.../ClientHighAvailabilityServicesFactory.java} | 40 +++-----
...aultClientHighAvailabilityServicesFactory.java} | 30 ++----
.../HighAvailabilityServicesUtils.java | 18 ++--
.../flink/runtime/minicluster/MiniCluster.java | 2 +-
.../runtime/taskexecutor/TaskManagerRunner.java | 3 +-
.../apache/flink/runtime/util/ZooKeeperUtils.java | 36 ++++++-
.../runtime/zookeeper/ZooKeeperUtilityFactory.java | 114 ---------------------
.../ZKCheckpointIDCounterMultiServersTest.java | 4 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 13 ++-
.../ZooKeeperDefaultDispatcherRunnerTest.java | 4 +-
.../HighAvailabilityServicesUtilsTest.java | 13 ++-
.../zookeeper/ZooKeeperHaServicesTest.java | 4 +-
.../zookeeper/ZooKeeperRegistryTest.java | 4 +-
.../ZooKeeperJobGraphStoreWatcherTest.java | 5 +-
.../runtime/leaderelection/LeaderElectionTest.java | 5 +-
...KeeperLeaderElectionConnectionHandlingTest.java | 4 +-
.../ZooKeeperLeaderElectionTest.java | 21 +++-
...eeperLeaderRetrievalConnectionHandlingTest.java | 4 +-
.../ZooKeeperLeaderRetrievalTest.java | 4 +-
.../util/DocumentingDispatcherRestEndpoint.java | 8 --
.../util/NoOpFatalErrorHandler.java} | 13 ++-
.../TaskManagerRunnerConfigurationTest.java | 4 +-
.../flink/runtime/util/ZooKeeperUtilTest.java | 78 --------------
.../flink/runtime/util/ZooKeeperUtilsTest.java | 73 +++++++++++++
.../runtime/util/ZooKeeperUtilsTreeCacheTest.java | 11 +-
.../zookeeper/ZooKeeperStateHandleStoreTest.java | 9 +-
.../zookeeper/ZooKeeperTestEnvironment.java | 5 +-
.../zookeeper/ZooKeeperUtilityFactoryTest.java | 42 --------
.../JobManagerHAProcessFailureRecoveryITCase.java | 3 +-
.../recovery/ProcessFailureCancelingITCase.java | 4 +-
33 files changed, 264 insertions(+), 347 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{shuffle/ShuffleMasterContextImpl.java => highavailability/ClientHighAvailabilityServicesFactory.java} (56%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{shuffle/ShuffleMasterContextImpl.java => highavailability/DefaultClientHighAvailabilityServicesFactory.java} (57%)
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactory.java
copy flink-runtime/src/test/java/org/apache/flink/runtime/{operators/testutils/DiscardingOutputCollector.java => rest/util/NoOpFatalErrorHandler.java} (74%)
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/util/ZooKeeperUtilTest.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactoryTest.java