Repository: ignite Updated Branches: refs/heads/ignite-1093-2 57064970f -> 80ec3457c
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/80ec3457 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/80ec3457 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/80ec3457 Branch: refs/heads/ignite-1093-2 Commit: 80ec3457c27c9b27bb34356b6fefe1531400e06b Parents: 5706497 Author: Anton Vinogradov <[email protected]> Authored: Fri Oct 16 20:15:41 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Fri Oct 16 20:15:41 2015 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/GridDhtPartitionSupplier.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/80ec3457/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java index 00d1b9c..c7f1909 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java @@ -197,12 +197,14 @@ class GridDhtPartitionSupplier { try { cctx.io().sendOrderedMessage(cctx.localNode(), GridCachePartitionExchangeManager.rebalanceTopic(idx), d, cctx.ioPolicy(), cctx.config().getRebalanceTimeout()); + + log.info("Demand request resended [current=" + cctx.affinity().affinityTopologyVersion() + ", demanded=" + d.topologyVersion() + "]"); } catch (IgniteCheckedException e) { U.error(log, "Failed to resend partition supply message to local node: " + cctx.localNode().id()); } else if (log.isDebugEnabled()) - log.debug("Demand request cancelled [current=" + cctx.affinity().affinityTopologyVersion() + ", demanded=" + d.topologyVersion() + "]"); + log.info("Demand request cancelled [current=" + cctx.affinity().affinityTopologyVersion() + ", demanded=" + d.topologyVersion() + "]"); return; }
