add threshold for group result

121564de · Ganlin Zhao · 523f08fe · 121564de
显示空白变更内容
内联并排

Showing with 3 addition and 1 deletion

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

未找到文件。
--- a/source/libs/executor/src/timesliceoperator.c
+++ b/source/libs/executor/src/timesliceoperator.c
@@ -784,8 +784,10 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {

    // restore initial value for next group
    resetTimesliceInfo(pSliceInfo);
+    if (pResBlock->info.rows >= 4096) {
      break;
    }
+  }

  // restore the value
  setTaskStatus(pOperator->pTaskInfo, TASK_COMPLETED);