From 121564de2fe2079f181f1720396461d434863b5c Mon Sep 17 00:00:00 2001 From: Ganlin Zhao Date: Thu, 11 May 2023 10:04:25 +0800 Subject: [PATCH] add threshold for group result --- source/libs/executor/src/timesliceoperator.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/source/libs/executor/src/timesliceoperator.c b/source/libs/executor/src/timesliceoperator.c index 15a9ad9594..b7f7a44080 100644 --- a/source/libs/executor/src/timesliceoperator.c +++ b/source/libs/executor/src/timesliceoperator.c @@ -784,7 +784,9 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) { // restore initial value for next group resetTimesliceInfo(pSliceInfo); - break; + if (pResBlock->info.rows >= 4096) { + break; + } } // restore the value