From 43ac6fb1fd532c96f5deba1b21e46abd5b2e0762 Mon Sep 17 00:00:00 2001
From: shenglian zhou <shenglian_zhou@163.com>
Date: Tue, 23 May 2023 08:43:31 +0800
Subject: [PATCH] fix: all null from block sma

---
 source/libs/scalar/src/filter.c | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/source/libs/scalar/src/filter.c b/source/libs/scalar/src/filter.c
index 33f37c722e..4475a07dcd 100644
--- a/source/libs/scalar/src/filter.c
+++ b/source/libs/scalar/src/filter.c
@@ -3722,7 +3722,15 @@ int32_t fltSclBuildDatumFromBlockSmaValue(SFltSclDatum* datum, uint8_t type, int
   return TSDB_CODE_SUCCESS;
 }
 
-int32_t fltSclBuildRangeFromBlockSma(SFltSclColumnRange* colRange, SColumnDataAgg* pAgg, SArray* points) {
+int32_t fltSclBuildRangeFromBlockSma(SFltSclColumnRange* colRange, SColumnDataAgg* pAgg, int32_t numOfRows, SArray* points) {
+  if (pAgg->numOfNull == numOfRows) {
+    SFltSclDatum datum = {.kind = FLT_SCL_DATUM_KIND_NULL};
+    SFltSclPoint startPt = {.start = true, .excl = false, .val = datum};
+    SFltSclPoint endPt = {.start = false, .excl = false, .val = datum};
+    taosArrayPush(points, &startPt);
+    taosArrayPush(points, &endPt);
+    return TSDB_CODE_SUCCESS;
+  }
   SFltSclDatum min;
   fltSclBuildDatumFromBlockSmaValue(&min, colRange->colNode->node.resType.type, pAgg->min);
   SFltSclPoint minPt = {.excl = false, .start = true, .val = min};
@@ -3749,7 +3757,7 @@ bool filterRangeExecute(SFilterInfo *info, SColumnDataAgg **pDataStatis, int32_t
       if (foundCol) {
         SColumnDataAgg* pAgg = pDataStatis[j];
         SArray* points = taosArrayInit(2, sizeof(SFltSclPoint));
-        fltSclBuildRangeFromBlockSma(colRange, pAgg, points);
+        fltSclBuildRangeFromBlockSma(colRange, pAgg, numOfRows, points);
         SArray* merged = taosArrayInit(8, sizeof(SFltSclPoint));
         fltSclIntersect(points, colRange->points, merged);
         bool isIntersect = taosArrayGetSize(merged) != 0;