LuoGe
/
openGauss-server
forked from huawei/openGauss-server
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

解决ustore模式下，备机上运行逻辑解码和备机读业务，备机上每秒打印约百条日志：WARNING: [CheckLastRecordSize:503]last record size 697 != xlog last record size 689 

Offering: openGaussDev

More detail: 解决ustore模式下，备机上运行逻辑解码和备机读业务，备机上每秒打印约百条日志：WARNING: [CheckLastRecordSize:503]last record size 697 != xlog last record size 689

Match-id-bafd821a73fa2dba5919b38c1af024cc6761f938
This commit is contained in:
openGaussDev 2022-03-04 19:26:29 +08:00 committed by yanghao
parent 1b7cc1bc75
commit 0f699af7b6
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/gausskernel/storage/access/ustore/knl_uredo.cpp
View File

@ -356,7 +356,8 @@ static UndoRecPtr PrepareAndInsertUndoRecordForDeleteRedo(XLogReaderState *recor
* If the WAL stream contains undo tuple, then replace it with the * If the WAL stream contains undo tuple, then replace it with the
* explicitly stored tuple. * explicitly stored tuple.
*/ */
Size datalen = recordlen - SizeOfXLUndoHeader - SizeOfUHeapDelete - undoMetaSize - SizeOfUHeapHeader - readSize; Size datalen = recordlen - SizeOfXLUndoHeader - SizeOfUHeapDelete - undoMetaSize - SizeOfUHeapHeader -
readSize - (hasCSN ? sizeof(CommitSeqNo) : 0);
char *data = (char *)xlrec + SizeOfUHeapDelete + SizeOfXLUndoHeader + undoMetaSize + readSize; char *data = (char *)xlrec + SizeOfUHeapDelete + SizeOfXLUndoHeader + undoMetaSize + readSize;
utup->disk_tuple = GetUHeapDiskTupleFromRedoData(data, &datalen, tbuf, false); utup->disk_tuple = GetUHeapDiskTupleFromRedoData(data, &datalen, tbuf, false);
@ -856,8 +857,8 @@ static UndoRecPtr PrepareAndInsertUndoRecordForUpdateRedo(XLogReaderState *recor
} }
char *data = (char *)curxlogptr; char *data = (char *)curxlogptr;
Size datalen = recordlen - SizeOfUHeapHeader - SizeOfXLUndoHeader - SizeOfUHeapUpdate - Size datalen = recordlen - SizeOfUHeapHeader - SizeOfXLUndoHeader - SizeOfUHeapUpdate -
undoMetaSize - SizeOfXLUndoHeader - initPageXtraInfo - readSize; undoMetaSize - SizeOfXLUndoHeader - initPageXtraInfo - readSize - (hasCSN ? sizeof(CommitSeqNo) : 0);
oldtup->disk_tuple = GetUHeapDiskTupleFromRedoData(data, &datalen, tbuf, false); oldtup->disk_tuple = GetUHeapDiskTupleFromRedoData(data, &datalen, tbuf, false);
oldtup->disk_tuple_size = datalen; oldtup->disk_tuple_size = datalen;