diff --git a/source/libs/executor/src/timesliceoperator.c b/source/libs/executor/src/timesliceoperator.c
index 15a9ad95946776aba7a503b19775d902899cda2e..b7f7a44080da1fa8a8f96e5972460c532841d577 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