Repository: ignite Updated Branches: refs/heads/ignite-zk 8d501d47b -> 22764fa00
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/22764fa0 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/22764fa0 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/22764fa0 Branch: refs/heads/ignite-zk Commit: 22764fa0050c89b2eec8a21286c41ffd35b28778 Parents: 8d501d4 Author: sboikov <[email protected]> Authored: Fri Jan 12 14:16:36 2018 +0300 Committer: sboikov <[email protected]> Committed: Fri Jan 12 14:16:36 2018 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/22764fa0/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java index 361661b..4cd0365 100644 --- a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java +++ b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java @@ -812,7 +812,9 @@ public class ZookeeperDiscoveryImpl { List<String> dirs = new ArrayList<>(); for (String dir : requiredDirs) { - if (!createdDirs.contains(dir)) + String dir0 = dir.substring(zkPaths.clusterDir.length() + 1); + + if (!createdDirs.contains(dir0)) dirs.add(dir); }
