From 21fccc2d48224439ccd9ab37f0e97e088075e323 Mon Sep 17 00:00:00 2001
From: Ganlin Zhao <ganlinzhao@hotmail.com>
Date: Thu, 8 Jun 2023 18:25:32 +0800
Subject: [PATCH] fix switchin group issue

---
 source/libs/executor/src/timesliceoperator.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/timesliceoperator.c b/source/libs/executor/src/timesliceoperator.c
index 1aa6027a1d..8006235391 100644
--- a/source/libs/executor/src/timesliceoperator.c
+++ b/source/libs/executor/src/timesliceoperator.c
@@ -903,7 +903,7 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
         goto _finished;
       }
     }
-    // handling post work for a specific group
+    // post work for a specific group
 
     // check if need to interpolate after last datablock
     // except for fill(next), fill(linear)
@@ -916,6 +916,9 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
 
     // restore initial value for next group
     resetTimesliceInfo(pSliceInfo);
+    if (checkThresholdReached(pSliceInfo, pOperator->resultInfo.threshold)) {
+      goto _finished;
+    }
   }
 
 _finished: