You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2016/02/12 15:13:25 UTC
ignite git commit: Added multi-node restart + SQL tests.
Repository: ignite
Updated Branches:
refs/heads/sql-store bfe54b503 -> d17497651
Added multi-node restart + SQL tests.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d1749765
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d1749765
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d1749765
Branch: refs/heads/sql-store
Commit: d1749765152e4bff337f7151050b6be0a1a284b5
Parents: bfe54b5
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Fri Feb 12 17:13:12 2016 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Fri Feb 12 17:13:12 2016 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/d1749765/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
index 2ab8a12..b71a21f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
@@ -408,11 +408,17 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology {
"(it does not belong to affinity): " + locPart);
}
}
+ else
+ locPart.own();
}
else if (belongs) {
try {
// Pre-create partitions.
- localPartition(p, topVer, true, false);
+ GridDhtLocalPartition part = localPartition(p, topVer, true, false);
+
+ assert part != null;
+
+ part.own();
}
catch (GridDhtInvalidPartitionException e) {
if (log.isDebugEnabled())