diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index d0591de0114ab6b96be22140edfad5f90bb5b53b..60517a2f5ce72fdfa13b68167d6d731faf8428a3 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -135,6 +135,10 @@ static void tscProcessStreamTimer(void *handle, void *tmrId) {
       etime = pStream->stime + (etime - pStream->stime) / pStream->interval * pStream->interval;
     }
     pQueryInfo->window.ekey = etime;
+    if (pQueryInfo->window.skey >= pQueryInfo->window.ekey) {
+      tscSetRetryTimer(pStream, pSql, pStream->slidingTime);
+      return;
+    }
   }
 
   // launch stream computing in a new thread
diff --git a/tests/pytest/stream/new.py b/tests/pytest/stream/new.py
index b8503f0b4e82b8fded5ef92bfa87a1180d69037a..eac93dc0e649f5d48481079d75851a27be270567 100644
--- a/tests/pytest/stream/new.py
+++ b/tests/pytest/stream/new.py
@@ -54,7 +54,7 @@ class TDTestCase:
                 tdSql.execute("insert into tb%d values(now + %ds, %d, %d)" % (i, j, j, j))
 
         tdLog.info("=============== step5")
-        tdLog.sleep(30)
+        tdLog.sleep(40)
         tdSql.waitedQuery("select * from st order by ts desc", 1, 120)
         v = tdSql.getData(0, 3)
         if v <= 51: