fix: when no file block, no proc mem before fileset
This commit is contained in:
parent
5bf364cc0a
commit
d3146a5bec
|
@ -4361,12 +4361,18 @@ static int32_t doTsdbNextDataBlockFilesetDelimited(STsdbReader* pReader) {
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pStatus->bProcMemPreFileset && pBlock->info.rows > 0) {
|
tsdbTrace("block from file rows: %"PRId64", will process pre-file set buffer: %d. %s",
|
||||||
pStatus->pNextFilesetBlock = createOneDataBlock(pBlock, true);
|
pBlock->info.rows, pStatus->bProcMemFirstFileset, pReader->idStr);
|
||||||
blockDataCleanup(pBlock);
|
if (pStatus->bProcMemPreFileset) {
|
||||||
code = buildFromPreFilesetBuffer(pReader);
|
if ( pBlock->info.rows > 0) {
|
||||||
if (code != TSDB_CODE_SUCCESS || pBlock->info.rows > 0) {
|
pStatus->pNextFilesetBlock = createOneDataBlock(pBlock, true);
|
||||||
return code;
|
blockDataCleanup(pBlock);
|
||||||
|
code = buildFromPreFilesetBuffer(pReader);
|
||||||
|
if (code != TSDB_CODE_SUCCESS || pBlock->info.rows > 0) {
|
||||||
|
return code;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
pStatus->bProcMemPreFileset = false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue