tillrohrmann commented on a change in pull request #17485:
URL: https://github.com/apache/flink/pull/17485#discussion_r791531251
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
##########
@@ -137,17 +155,37 @@ public static String getCheckpointIdCounterPath() {
return "/checkpoint_id_counter";
}
+ public static String getLeaderPath() {
+ return LEADER_NODE;
+ }
+
+ public static String getDispatcherNode() {
+ return DISPATCHER_LEADER;
+ }
+
+ public static String getResourceManagerNode() {
+ return RESOURCE_MANAGER_LEADER;
+ }
+
+ public static String getRestServerNode() {
+ return REST_SERVER_LEADER;
+ }
+
+ public static String getLeaderLatchNode() {
+ return LEADER_LATCH_NODE;
+ }
+
private static String getLeaderPath(String suffix) {
return generateZookeeperPath(LEADER_NODE, suffix);
}
@Nonnull
Review comment:
True, but I haven't touched this code in this PR. Can be a follow-up
task.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
