diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 60517a2f5ce72fdfa13b68167d6d731faf8428a3..9dd47888d21d7626646a377429a66beadda837ea 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -136,7 +136,11 @@ static void tscProcessStreamTimer(void *handle, void *tmrId) {
     }
     pQueryInfo->window.ekey = etime;
     if (pQueryInfo->window.skey >= pQueryInfo->window.ekey) {
-      tscSetRetryTimer(pStream, pSql, pStream->slidingTime);
+      int64_t timer = pStream->slidingTime;
+      if (pStream->precision == TSDB_TIME_PRECISION_MICRO) {
+        timer /= 1000l;
+      }
+      tscSetRetryTimer(pStream, pSql, timer);
       return;
     }
   }