[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-04-12 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1163923621 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -205,20 +208,7 @@ public void onGrantLeadership(UUID newLe

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-04-12 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1163923621 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -205,20 +208,7 @@ public void onGrantLeadership(UUID newLe

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-04-12 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1163923621 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -205,20 +208,7 @@ public void onGrantLeadership(UUID newLe

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-04-11 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1162646690 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-04-11 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1162646690 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-02-13 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1104142315 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-02-08 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1099989601 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-02-08 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1099989601 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-02-07 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1098595984 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-02-07 Thread via GitHub
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1082832944 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-01-20 Thread GitBox
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1082832944 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-01-20 Thread GitBox
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1082832944 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception

[GitHub] [flink] XComp commented on a diff in pull request #21742: [FLINK-30765][runtime] Aligns the LeaderElectionService.stop() contract

2023-01-20 Thread GitBox
XComp commented on code in PR #21742: URL: https://github.com/apache/flink/pull/21742#discussion_r1082817072 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java: ## @@ -100,6 +100,7 @@ public final void stop() throws Exception