more code

This commit is contained in:
Hongze Cheng 2024-03-06 17:56:35 +08:00
parent 3cb2838202
commit b6c71d8a43
1 changed files with 11 additions and 2 deletions

View File

@ -876,8 +876,17 @@ int32_t tsdbSttFileWriteRow(SSttFileWriter *writer, SRowInfo *row) {
.lastKey = key.key,
.count = 1,
};
code = tStatisBlockPut(writer->staticBlock, &record);
TSDB_CHECK_CODE(code, lino, _exit);
for (;;) {
code = tStatisBlockPut(writer->staticBlock, &record);
if (code == TSDB_CODE_INVALID_PARA) {
code = tsdbSttFileDoWriteStatisBlock(writer);
TSDB_CHECK_CODE(code, lino, _exit);
continue;
} else {
TSDB_CHECK_CODE(code, lino, _exit);
}
break;
}
} else {
// update last key and count
STbStatisRecord record;