Repository: ignite Updated Branches: refs/heads/ignite-2.7 beb7eb0b2 -> 59060d375
IGNITE-9705 Fix flushes invalid byte buffer into snapshot manager - Fixes #4841. Signed-off-by: Dmitriy Govorukhin <[email protected]> (cherry picked from commit 76d6ef032f9a634f15398d10e0019419f9798296) Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/59060d37 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/59060d37 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/59060d37 Branch: refs/heads/ignite-2.7 Commit: 59060d375031c3f21ea7b0ca5a314c523500fea8 Parents: beb7eb0 Author: ibessonov <[email protected]> Authored: Thu Oct 4 11:29:24 2018 +0300 Committer: Dmitriy Govorukhin <[email protected]> Committed: Thu Oct 4 11:32:07 2018 +0300 ---------------------------------------------------------------------- .../cache/persistence/GridCacheDatabaseSharedManager.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/59060d37/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java index 14f8fe6..d54a64f 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java @@ -1082,6 +1082,8 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan // First of all, write page to disk. storeMgr.write(fullId.groupId(), fullId.pageId(), pageBuf, tag); + pageBuf.rewind(); + // Only after write we can write page into snapshot. snapshotMgr.flushDirtyPageHandler(fullId, pageBuf, tag);
