fix(tsdb): fix invalid read.
This commit is contained in:
parent
fbb604d1f5
commit
e008d0f440
|
@ -3766,6 +3766,7 @@ int32_t buildDataBlockFromBufImpl(STableBlockScanInfo* pBlockScanInfo, int64_t e
|
||||||
}
|
}
|
||||||
|
|
||||||
if (row.type == TSDBROW_ROW_FMT) {
|
if (row.type == TSDBROW_ROW_FMT) {
|
||||||
|
int64_t ts = row.pTSRow->ts;;
|
||||||
code = doAppendRowFromTSRow(pBlock, pReader, row.pTSRow, pBlockScanInfo);
|
code = doAppendRowFromTSRow(pBlock, pReader, row.pTSRow, pBlockScanInfo);
|
||||||
|
|
||||||
if (freeTSRow) {
|
if (freeTSRow) {
|
||||||
|
@ -3776,7 +3777,7 @@ int32_t buildDataBlockFromBufImpl(STableBlockScanInfo* pBlockScanInfo, int64_t e
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
pBlockScanInfo->lastProcKey = row.pTSRow->ts;
|
pBlockScanInfo->lastProcKey = ts;
|
||||||
} else {
|
} else {
|
||||||
code = doAppendRowFromFileBlock(pBlock, pReader, row.pBlockData, row.iRow);
|
code = doAppendRowFromFileBlock(pBlock, pReader, row.pBlockData, row.iRow);
|
||||||
if (code) {
|
if (code) {
|
||||||
|
|
Loading…
Reference in New Issue