You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/10/30 15:23:52 UTC
ignite git commit: IGNITE-6793 More debug output
Repository: ignite
Updated Branches:
refs/heads/master 58dbbc539 -> 0134f2b44
IGNITE-6793 More debug output
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0134f2b4
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0134f2b4
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0134f2b4
Branch: refs/heads/master
Commit: 0134f2b4447c97c0bf3ddb4fac3b423248030eec
Parents: 58dbbc5
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Mon Oct 30 18:18:53 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Mon Oct 30 18:19:36 2017 +0300
----------------------------------------------------------------------
.../dht/preloader/InitNewCoordinatorFuture.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/0134f2b4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
index b5acd4b..596fa8c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
@@ -38,6 +38,7 @@ import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
import org.apache.ignite.internal.util.future.GridCompoundFuture;
import org.apache.ignite.internal.util.future.GridFutureAdapter;
import org.apache.ignite.internal.util.typedef.F;
+import org.apache.ignite.internal.util.typedef.internal.U;
import org.jetbrains.annotations.Nullable;
import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
@@ -113,6 +114,10 @@ public class InitNewCoordinatorFuture extends GridCompoundFuture {
nodes.add(node);
}
+ else if (!node.isLocal()) {
+ if (log.isInfoEnabled())
+ log.info("Init new coordinator future will skip remote node: " + node);
+ }
}
if (exchFut.context().mergeExchanges() && !curDiscoCache.version().equals(discoCache.version())) {
@@ -148,8 +153,10 @@ public class InitNewCoordinatorFuture extends GridCompoundFuture {
}
if (log.isInfoEnabled()) {
- log.info("Try restore exchange result [allNodes=" + awaited +
- ", joined=" + joinedNodes.keySet() + ']');
+ log.info("Try restore exchange result [awaited=" + awaited +
+ ", joined=" + joinedNodes.keySet() +
+ ", nodes=" + U.nodeIds(nodes) +
+ ", discoAllNodes=" + U.nodeIds(discoCache.allNodes()) + ']');
}
if (!nodes.isEmpty()) {