Repository: ignite Updated Branches: refs/heads/ignite-db-x-10884 [created] d69f6ea23
Fixed extra partition calculation Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/533357da Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/533357da Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/533357da Branch: refs/heads/ignite-db-x-10884 Commit: 533357da917e7e34f4c46a19ccd2191a0876787e Parents: 8a25aed Author: Alexey Goncharuk <[email protected]> Authored: Mon Apr 4 20:13:40 2016 -0700 Committer: Alexey Goncharuk <[email protected]> Committed: Mon Apr 4 20:13:40 2016 -0700 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/533357da/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 f75744c..4384b27 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 @@ -674,7 +674,7 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { * =================================================== */ - GridDhtLocalPartition loc = localPartition(cctx.affinity().partition(e.key()), topologyVersion(), false); + GridDhtLocalPartition loc = localPartition(e.partition(), topologyVersion(), false); if (loc != null) loc.onRemoved(e);
