[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-03 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701730081 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -113,7 +116,16 @@ public String

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-02 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701377710 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -213,7 +234,16 @@ private

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-02 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701266272 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -184,12 +184,32 @@ public

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-02 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701175663 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -224,11 +229,34 @@ public static CuratorFramework

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-01 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699412949 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/ZooKeeperUtilsTest.java ## @@ -44,4 +58,27 @@ private void

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-01 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r700016263 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -224,11 +229,30 @@ public static CuratorFramework

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-01 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r700012472 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] tillrohrmann commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-08-31 Thread GitBox
tillrohrmann commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699412949 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/ZooKeeperUtilsTest.java ## @@ -44,4 +58,27 @@ private void