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 <[email protected]> Authored: Fri Sep 18 12:37:25 2015 +0300 Committer: Anton Vinogradov <[email protected]> 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()); }
