Repository: ignite Updated Branches: refs/heads/ignite-zk-alpha ec93ee5d5 -> afa221498
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/afa22149 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/afa22149 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/afa22149 Branch: refs/heads/ignite-zk-alpha Commit: afa2214983ff6207b7195b0c385c0e1e60bd7329 Parents: ec93ee5 Author: sboikov <[email protected]> Authored: Fri Dec 8 15:01:00 2017 +0300 Committer: sboikov <[email protected]> Committed: Fri Dec 8 15:01:00 2017 +0300 ---------------------------------------------------------------------- .../spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/afa22149/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java index caa60ea..9b43fb45 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java @@ -2476,13 +2476,9 @@ public class ZookeeperDiscoveryImpl { return; try { - if (evt.getType() == Event.EventType.NodeDeleted) { + if (evt.getType() == Event.EventType.NodeDeleted) onPreviousNodeFail(); - } else { - if (log.isInfoEnabled()) - log.info("Previous node watch event: " + evt); - if (evt.getType() != Event.EventType.None) rtState.zkClient.existsAsync(evt.getPath(), this, this); } @@ -2500,8 +2496,6 @@ public class ZookeeperDiscoveryImpl { return; try { - log.info("Previous node stat callback [rc=" + rc + ", path=" + path + ", stat=" + stat + ']'); - assert rc == 0 || rc == KeeperException.Code.NONODE.intValue() : KeeperException.Code.get(rc); if (rc == KeeperException.Code.NONODE.intValue() || stat == null)
