Repository: ignite Updated Branches: refs/heads/ignite-6778 98ca614b4 -> ba9cee15a
IGNITE-6641 Fixed partition ID handling improvement Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fc1dcc39 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fc1dcc39 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fc1dcc39 Branch: refs/heads/ignite-6778 Commit: fc1dcc392313136dd8cc8f1b4142e879528b19c6 Parents: 2f468d8 Author: Sergey Chugunov <[email protected]> Authored: Wed Nov 1 13:12:35 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Wed Nov 1 13:12:35 2017 +0300 ---------------------------------------------------------------------- .../processors/cache/persistence/freelist/io/PagesListNodeIO.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fc1dcc39/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/freelist/io/PagesListNodeIO.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/freelist/io/PagesListNodeIO.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/freelist/io/PagesListNodeIO.java index a93cdf3..8eba4b1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/freelist/io/PagesListNodeIO.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/freelist/io/PagesListNodeIO.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.cache.persistence.freelist.io; import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.pagemem.PageIdUtils; import org.apache.ignite.internal.pagemem.PageUtils; import org.apache.ignite.internal.processors.cache.persistence.tree.io.IOVersions; import org.apache.ignite.internal.processors.cache.persistence.tree.io.PageIO; @@ -210,7 +211,7 @@ public class PagesListNodeIO extends PageIO { int cnt = getCount(pageAddr); for (int i = 0; i < cnt; i++) { - if (getAt(pageAddr, i) == dataPageId) { + if (PageIdUtils.maskPartitionId(getAt(pageAddr, i)) == PageIdUtils.maskPartitionId(dataPageId)) { if (i != cnt - 1) copyMemory(pageAddr, offset(i + 1), pageAddr, offset(i), 8 * (cnt - i - 1));
