diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c index 31af78f6188477b8a1866cd20dfe35c4c12018cd..a1ee54a5ac044335f5bc33b5cf5bab5da3420951 100644 --- a/src/client/src/tscStream.c +++ b/src/client/src/tscStream.c @@ -382,6 +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 } static int64_t tscGetStreamStartTimestamp(SSqlObj *pSql, SSqlStream *pStream, int64_t stime) {