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 <[email protected]> Authored: Mon Oct 30 18:18:53 2017 +0300 Committer: Alexey Goncharuk <[email protected]> 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()) {
