From 7a7165152e655e2633856a22ce5138ea8da68337 Mon Sep 17 00:00:00 2001 From: Koji Kawamura Date: Thu, 4 Aug 2016 17:16:21 +0900 Subject: [PATCH] NIFI-2478 Fixed Zk leaders path to include root. --- .../leader/election/CuratorLeaderElectionManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/leader/election/CuratorLeaderElectionManager.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/leader/election/CuratorLeaderElectionManager.java index 19fa2259a9..94c83df6ab 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/leader/election/CuratorLeaderElectionManager.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/leader/election/CuratorLeaderElectionManager.java @@ -95,7 +95,7 @@ public class CuratorLeaderElectionManager implements LeaderElectionManager { } final String rootPath = zkConfig.getRootPath(); - final String leaderPath = (rootPath.endsWith("/") ? "" : "/") + "leaders/" + roleName; + final String leaderPath = rootPath + (rootPath.endsWith("/") ? "" : "/") + "leaders/" + roleName; try { PathUtils.validatePath(rootPath);