fix td-1150

c5ae6d2a · Bomin Zhang · afd940d9 · c5ae6d2a
隐藏空白更改
内联并排

Showing with 5 addition and 1 deletion

src/client/src/tscStream.c src/client/src/tscStream.c +5 -1

未找到文件。
--- 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;
    }
  }