ignite-db - inner replace on put
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ac0b698e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ac0b698e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ac0b698e Branch: refs/heads/ignite-db-x-10884 Commit: ac0b698e635f688d23d1d8d2b8b134c495ad7d47 Parents: d783279 Author: S.Vladykin <[email protected]> Authored: Tue Apr 12 11:00:32 2016 +0300 Committer: S.Vladykin <[email protected]> Committed: Tue Apr 12 11:00:32 2016 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/query/h2/database/BPlusTree.java | 3 ++- .../processors/database/IgniteDbSingleNodePutGetSelfTest.java | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ac0b698e/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/BPlusTree.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/BPlusTree.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/BPlusTree.java index 4fde3f4..5258dd4 100644 --- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/BPlusTree.java +++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/BPlusTree.java @@ -1724,7 +1724,8 @@ public abstract class BPlusTree<L, T extends L> { if (io.isLeaf()) return true; - if (foundInner == FALSE) + // If we can get full row from the inner page, we must do inner replace to update full row info here. + if (io.canGetRow() && foundInner == FALSE) foundInner = TRUE; return false; http://git-wip-us.apache.org/repos/asf/ignite/blob/ac0b698e/modules/indexing/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodePutGetSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodePutGetSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodePutGetSelfTest.java index 575ccaf..cbb12e7 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodePutGetSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodePutGetSelfTest.java @@ -462,7 +462,7 @@ public class IgniteDbSingleNodePutGetSelfTest extends GridCommonAbstractTest { X.println("Start removing."); for (int i = 0; i < cnt; i++) { - if (i % 100 == 0) { + if (i % 1000 == 0) { X.println("-> " + i); // assertEquals((long)(cnt - i), @@ -505,7 +505,7 @@ public class IgniteDbSingleNodePutGetSelfTest extends GridCommonAbstractTest { X.println("Start removing in backward direction."); for (int i = cnt - 1; i >= 0; i--) { - if (i % 100 == 0) { + if (i % 1000 == 0) { X.println("-> " + i); // assertEquals((long)(cnt - i),
