From 52a04cd00822576b90dc38ed80c40211285cbd3b Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 26 Mar 2024 10:55:56 +0800 Subject: [PATCH] fix(tsdb): fix bug for filter brin record. --- source/dnode/vnode/src/tsdb/tsdbRead2.c | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbRead2.c b/source/dnode/vnode/src/tsdb/tsdbRead2.c index 7505230eca..c7164d43de 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRead2.c +++ b/source/dnode/vnode/src/tsdb/tsdbRead2.c @@ -709,9 +709,14 @@ static int32_t doLoadFileBlock(STsdbReader* pReader, SArray* pIndexList, SBlockN continue; } - int32_t ret = pkCompEx(pReader->pkComparFn, &pRecord->lastKey.key, &pScanInfo->lastProcKey); - if ((asc && ret <= 0) || (!asc && ret >= 0)) { - continue; + if (asc) { + if (pkCompEx(pReader->pkComparFn, &pRecord->lastKey.key, &pScanInfo->lastProcKey) <= 0) { + continue; + } + } else { + if (pkCompEx(pReader->pkComparFn, &pRecord->firstKey.key, &pScanInfo->lastProcKey) >= 0) { + continue; + } } // 2. version range check, version range is an CLOSED interval