xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add check

This commit is contained in:
54liuyao 2024-09-29 14:53:47 +08:00
parent 7517228dde
commit 2c0445fff4
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/tstreamFileState.c
View File

@ -445,7 +445,9 @@ _end:
} }
int32_t clearRowBuff(SStreamFileState* pFileState) { int32_t clearRowBuff(SStreamFileState* pFileState) {
clearExpiredRowBuff(pFileState, pFileState->maxTs - pFileState->deleteMark, false); if (pFileState->deleteMark != INT64_MAX) {
clearExpiredRowBuff(pFileState, pFileState->maxTs - pFileState->deleteMark, false);
}
if (isListEmpty(pFileState->freeBuffs)) { if (isListEmpty(pFileState->freeBuffs)) {
return flushRowBuff(pFileState); return flushRowBuff(pFileState);
} }