From b6c71d8a43ab23733ca5c3dc4f07611a89dc2ba7 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Wed, 6 Mar 2024 17:56:35 +0800 Subject: [PATCH] more code --- source/dnode/vnode/src/tsdb/tsdbSttFileRW.c | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbSttFileRW.c b/source/dnode/vnode/src/tsdb/tsdbSttFileRW.c index 2c2b3c8f82..1da08b89f0 100644 --- a/source/dnode/vnode/src/tsdb/tsdbSttFileRW.c +++ b/source/dnode/vnode/src/tsdb/tsdbSttFileRW.c @@ -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;