Repository: ignite Updated Branches: refs/heads/ignite-zk 6d4a32dde -> 39edd4b56
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/39edd4b5 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/39edd4b5 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/39edd4b5 Branch: refs/heads/ignite-zk Commit: 39edd4b563a66275d5334888596f39923d4d7f40 Parents: 6d4a32d Author: sboikov <[email protected]> Authored: Mon Dec 11 14:10:59 2017 +0300 Committer: sboikov <[email protected]> Committed: Mon Dec 11 14:10:59 2017 +0300 ---------------------------------------------------------------------- .../spi/discovery/zk/internal/ZkInternalForceNodeFailMessage.java | 2 +- .../ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/39edd4b5/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkInternalForceNodeFailMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkInternalForceNodeFailMessage.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkInternalForceNodeFailMessage.java index f2fb183..8d7a3df 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkInternalForceNodeFailMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkInternalForceNodeFailMessage.java @@ -24,7 +24,7 @@ import org.jetbrains.annotations.Nullable; /** * */ -public class ZkInternalForceNodeFailMessage implements DiscoverySpiCustomMessage, ZkInternalMessage { +public class ZkInternalForceNodeFailMessage implements DiscoverySpiCustomMessage, ZkInternalMessage { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/ignite/blob/39edd4b5/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 744f2c9..5190329 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 @@ -1568,6 +1568,8 @@ public class ZookeeperDiscoveryImpl { else { if (log.isDebugEnabled()) log.debug("Ignore forcible node fail request for unknown node: " + msg0.nodeId); + + continue; } }
