fix:return empty ssdatablock

933fa721 · 54liuyao · aeb46416 · 933fa721
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +3 -1

未找到文件。
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -1907,7 +1907,9 @@ FETCH_NEXT_BLOCK:
        doFilter(pInfo->pRes, pOperator->exprSupp.pFilterInfo, NULL);
        pInfo->pRes->info.dataLoad = 1;
        blockDataUpdateTsWindow(pInfo->pRes, pInfo->primaryTsIndex);
-        return pInfo->pRes;
+        if (pInfo->pRes->info.rows > 0) {
+          return pInfo->pRes;
+        }
      } break;
      case STREAM_SCAN_FROM_DELETE_DATA: {
        generateScanRange(pInfo, pInfo->pUpdateDataRes, pInfo->pUpdateRes);