fix block only have one row

2023-06-08 19:21:04 +08:00 · 2023-06-08 19:21:04 +08:00 · 145bb93967
parent 21fccc2d48
commit 145bb93967
1 changed files with 3 additions and 0 deletions
--- a/source/libs/executor/src/timesliceoperator.c
+++ b/source/libs/executor/src/timesliceoperator.c
@ -875,6 +875,9 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
      doHandleTimeslice(pOperator, pSliceInfo->pNextGroupRes);
      if (checkThresholdReached(pSliceInfo, pOperator->resultInfo.threshold)) {
        doFilter(pResBlock, pOperator->exprSupp.pFilterInfo, NULL);
+        if (pSliceInfo->pRemainRes == NULL) {
+          pSliceInfo->pNextGroupRes = NULL;
+        }
        goto _finished;
      }
      pSliceInfo->pNextGroupRes = NULL;