Skip to content

Commit

Permalink
IGNITE-6793 More debug output
Browse files Browse the repository at this point in the history
  • Loading branch information
agoncharuk committed Oct 30, 2017
1 parent 58dbbc5 commit 0134f2b
Showing 1 changed file with 9 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@
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;
Expand Down Expand Up @@ -113,6 +114,10 @@ public void init(GridDhtPartitionsExchangeFuture exchFut) throws IgniteCheckedEx

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())) {
Expand Down Expand Up @@ -148,8 +153,10 @@ public void init(GridDhtPartitionsExchangeFuture exchFut) throws IgniteCheckedEx
}

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()) {
Expand Down

0 comments on commit 0134f2b

Please sign in to comment.