You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by dp...@apache.org on 2019/04/23 13:18:13 UTC
[ignite] branch ignite-11796 created (now 6ffe429)
This is an automated email from the ASF dual-hosted git repository.
dpavlov pushed a change to branch ignite-11796
in repository https://gitbox.apache.org/repos/asf/ignite.git.
at 6ffe429 IGNITE-11796: Fix for WAL recovery stopped with 'Partition consistency failure: newPageId'
This branch includes the following new commits:
new 6ffe429 IGNITE-11796: Fix for WAL recovery stopped with 'Partition consistency failure: newPageId'
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[ignite] 01/01: IGNITE-11796: Fix for WAL recovery stopped with
'Partition consistency failure: newPageId'
Posted by dp...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
dpavlov pushed a commit to branch ignite-11796
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 6ffe429efd393ed669348675df3bc207cf62d061
Author: Dmitriy Pavlov <dp...@apache.org>
AuthorDate: Tue Apr 23 16:17:42 2019 +0300
IGNITE-11796: Fix for WAL recovery stopped with 'Partition consistency failure: newPageId'
---
.../pagemem/wal/record/delta/InitNewPageRecord.java | 14 +++++++++++---
1 file changed, 11 insertions(+), 3 deletions(-)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/InitNewPageRecord.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/InitNewPageRecord.java
index 9ed7f35..c750d49 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/InitNewPageRecord.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/InitNewPageRecord.java
@@ -56,10 +56,18 @@ public class InitNewPageRecord extends PageDeltaRecord {
int newPartId = PageIdUtils.partId(newPageId);
int partId = PageIdUtils.partId(pageId);
- if (newPartId != partId) {
- throw new AssertionError("Partition consistency failure: " +
- "newPageId=" + Long.toHexString(newPageId) + " (newPartId: " + newPartId + ") " +
+ if (newPartId == 0 && newPartId != partId) {
+ U.warn(null, "Partition consistency warning: " +
+ "newPageId=" + Long.toHexString(newPageId) + " (newPartId: 0) " +
"pageId=" + Long.toHexString(pageId) + " (partId: " + partId + ")");
+
+ // Partition consistency failure came from https://issues.apache.org/jira/browse/IGNITE-11030
+ // This invalid record can come from persistent stores, version < 2.7.5 where this bug was not fixed.
+ newPartId = partId; // Just hack new page ID to make this record to be correctly applied.
+ this.newPageId = PageIdUtils.pageId(
+ newPartId,
+ PageIdUtils.flag(newPageId),
+ PageIdUtils.pageIndex(newPageId));
}
}