You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/09/22 13:13:35 UTC
[08/16] ignite git commit: 1093
1093
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/65a9c289
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/65a9c289
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/65a9c289
Branch: refs/heads/ignite-1093-2
Commit: 65a9c289b4aeaa1b8d984328072f8458e0d0d504
Parents: 7d51f61
Author: Anton Vinogradov <av...@apache.org>
Authored: Fri Sep 18 12:37:25 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Sep 18 12:37:25 2015 +0300
----------------------------------------------------------------------
.../distributed/dht/preloader/GridDhtPartitionDemander.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/65a9c289/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
index 3c5a2f2..498b16d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
@@ -852,7 +852,8 @@ public class GridDhtPartitionDemander {
assert remaining.isEmpty();
if (assigns.topologyVersion().topologyVersion() > 1)// Not an initial topology.
- U.log(log, "Rebalancing is not required [cache=" + cctx.name() +
+ if (log.isDebugEnabled())
+ log.debug("Rebalancing is not required [cache=" + cctx.name() +
", topology=" + assigns.topologyVersion() + "]");
checkIsDone();
@@ -1010,8 +1011,7 @@ public class GridDhtPartitionDemander {
}
if (!m.isEmpty()) {
- if (log.isDebugEnabled())
- log.debug("Reassigning partitions that were missed: " + m);
+ U.log(log,("Reassigning partitions that were missed: " + m));
cctx.shared().exchange().forceDummyExchange(true, assigns.exchangeFuture());
}