diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index a1ee54a5ac044335f5bc33b5cf5bab5da3420951..cd2736e9103b4b2af8b1ecf927b214a699a80bf3 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -382,7 +382,7 @@ static void tscSetSlidingWindowInfo(SSqlObj *pSql, SSqlStream *pStream) {
   }
 
   pStream->slidingTime = pCmd->nSlidingTime;
-  pQueryInfo->nAggTimeInterval = 0; // clear the interval value to avoid the force time window split by query processor
+  pCmd->nAggTimeInterval = 0; // clear the interval value to avoid the force time window split by query processor
 }
 
 static int64_t tscGetStreamStartTimestamp(SSqlObj *pSql, SSqlStream *pStream, int64_t stime) {