From 04227904ea1ec05d136f9b671700d3c8247058ca Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 12 Apr 2024 18:30:02 +0800 Subject: [PATCH] fix(tsdb): adjust assert. --- source/dnode/vnode/src/tsdb/tsdbMergeTree.c | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbMergeTree.c b/source/dnode/vnode/src/tsdb/tsdbMergeTree.c index 36320350d2..b70e607017 100644 --- a/source/dnode/vnode/src/tsdb/tsdbMergeTree.c +++ b/source/dnode/vnode/src/tsdb/tsdbMergeTree.c @@ -423,7 +423,9 @@ static int32_t loadSttStatisticsBlockData(SSttFileReader *pSttFileReader, SSttBl } } - ASSERT(taosArrayGetSize(pBlockLoadInfo->info.pLastKey) == taosArrayGetSize(pBlockLoadInfo->info.pFirstTs)); + if (block.numOfPKs > 0) { + ASSERT(taosArrayGetSize(pBlockLoadInfo->info.pLastKey) == taosArrayGetSize(pBlockLoadInfo->info.pFirstTs)); + } } else { STbStatisRecord record = {0}; @@ -452,7 +454,10 @@ static int32_t loadSttStatisticsBlockData(SSttFileReader *pSttFileReader, SSttBl } i += 1; - ASSERT(taosArrayGetSize(pBlockLoadInfo->info.pLastKey) == taosArrayGetSize(pBlockLoadInfo->info.pFirstTs)); + + if (record.firstKey.numOfPKs > 0) { + ASSERT(taosArrayGetSize(pBlockLoadInfo->info.pLastKey) == taosArrayGetSize(pBlockLoadInfo->info.pFirstTs)); + } } } }