From 4451b2185abb9922b81e71d747e7fa5577ba7caf Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Fri, 21 Jul 2023 10:32:53 +0800
Subject: [PATCH] transform stream state

---
 source/libs/executor/src/timewindowoperator.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c
index e8059afb2f..0a46def23d 100644
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -2753,6 +2753,7 @@ void streamIntervalReloadState(SOperatorInfo* pOperator) {
                                                         strlen(STREAM_INTERVAL_OP_STATE_NAME), &pBuf, &size);
     TSKEY ts = *(TSKEY*)pBuf;
     taosMemoryFree(pBuf);
+    pInfo->twAggSup.maxTs = TMAX(pInfo->twAggSup.maxTs, ts);
     pInfo->statestore.streamStateReloadInfo(pInfo->pState, ts);
   }
   SOperatorInfo* downstream = pOperator->pDownstream[0];
-- 
GitLab