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 2016/12/05 14:41:51 UTC
[29/50] [abbrv] ignite git commit: Rebalancing fixed to wait for
caches at public pool.
Rebalancing fixed to wait for caches at public pool.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b10ee4d1
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b10ee4d1
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b10ee4d1
Branch: refs/heads/ignite-comm-balance-master
Commit: b10ee4d1243245aa38a8d247831ae2eae5e50243
Parents: cf19932
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Nov 17 16:43:48 2016 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Nov 17 16:43:48 2016 +0300
----------------------------------------------------------------------
.../processors/cache/GridCachePartitionExchangeManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/b10ee4d1/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
index 4eb61e3..521a322 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
@@ -1645,7 +1645,7 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
fut.onDone();
}
}
- }, /*system pool*/true);
+ }, /*system pool*/false); //Todo: fix to not no use system pool properly.
}
else {
U.log(log, "Skipping rebalancing (obsolete exchange ID) " +