[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701897373 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -214,7 +216,19 @@ private RestClusterClient(

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701483653 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -110,10 +113,18 @@ public String

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701481899 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -213,7 +234,16 @@ private RestClusterClient(

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701214500 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -184,12 +184,32 @@ public RestClusterClient(

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701214500 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -184,12 +184,32 @@ public RestClusterClient(

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701211503 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -224,11 +229,34 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r701208062 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -184,12 +184,32 @@ public RestClusterClient(

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r700337494 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -224,11 +229,30 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699104914 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699753195 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699753195 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699742772 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699738100 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/ZooKeeperUtilsTest.java ## @@ -44,4 +58,27 @@ private void

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699737483 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699104914 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi 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
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699104914 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework