From 1ce6f1c1c7a4e1fd1243c80b11b2508cd675782a Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Mon, 29 Jul 2024 13:22:46 +0800
Subject: [PATCH] adj operator res

---
 source/libs/executor/src/streameventwindowoperator.c | 6 ++----
 tests/script/tsim/stream/session0.sim                | 8 ++++----
 tests/system-test/7-tmq/tmq_taosx.py                 | 1 -
 3 files changed, 6 insertions(+), 9 deletions(-)

diff --git a/source/libs/executor/src/streameventwindowoperator.c b/source/libs/executor/src/streameventwindowoperator.c
index 76eaccb4ec..17ef2fe41f 100644
--- a/source/libs/executor/src/streameventwindowoperator.c
+++ b/source/libs/executor/src/streameventwindowoperator.c
@@ -510,18 +510,16 @@ int32_t doStreamEventDecodeOpState(void* buf, int32_t len, SOperatorInfo* pOpera
   int32_t mapSize = 0;
   buf = taosDecodeFixedI32(buf, &mapSize);
   for (int32_t i = 0; i < mapSize; i++) {
-    SSessionKey       key = {0};
     SResultWindowInfo winfo = {0};
-    buf = decodeSSessionKey(buf, &key);
+    buf = decodeSSessionKey(buf, &winfo.sessionWin);
     int32_t winCode = TSDB_CODE_SUCCESS;
     code = pAggSup->stateStore.streamStateSessionAddIfNotExist(
         pAggSup->pState, &winfo.sessionWin, pAggSup->gap, (void**)&winfo.pStatePos, &pAggSup->resultRowSize, &winCode);
     QUERY_CHECK_CODE(code, lino, _end);
-    ASSERT(winCode == TSDB_CODE_SUCCESS);
 
     buf = decodeSResultWindowInfo(buf, &winfo, pInfo->streamAggSup.resultRowSize);
     code =
-        tSimpleHashPut(pInfo->streamAggSup.pResultRows, &key, sizeof(SSessionKey), &winfo, sizeof(SResultWindowInfo));
+        tSimpleHashPut(pInfo->streamAggSup.pResultRows, &winfo.sessionWin, sizeof(SSessionKey), &winfo, sizeof(SResultWindowInfo));
     QUERY_CHECK_CODE(code, lino, _end);
   }
 
diff --git a/tests/script/tsim/stream/session0.sim b/tests/script/tsim/stream/session0.sim
index 38adae4261..0d92070d10 100644
--- a/tests/script/tsim/stream/session0.sim
+++ b/tests/script/tsim/stream/session0.sim
@@ -189,11 +189,11 @@ run tsim/stream/checkTaskStatus.sim
 sql insert into t2 values(1648791213001,1,1,3,1.0,1);
 sql insert into t2 values(1648791213002,2,2,6,3.4,2);
 sql insert into t2 values(1648791213003,4,9,3,4.8,3);
-sql insert into t2 values(1648791233003,3,4,3,2.1,4);
-sql insert into t2 values(1648791233004,3,5,3,3.4,5);
-sql insert into t2 values(1648791233005,3,6,3,7.6,6);
 
-#
+sql insert into t2 values(1648791233003,3,4,3,2.1,4) (1648791233004,3,5,3,3.4,5) (1648791233005,3,6,3,7.6,6);
+
+sleep 1000
+
 sql insert into t2 values(1648791223003,20,7,3,10.1,7);
 
 $loop_count = 0
diff --git a/tests/system-test/7-tmq/tmq_taosx.py b/tests/system-test/7-tmq/tmq_taosx.py
index efa5f6b0f1..d30d88bb1c 100644
--- a/tests/system-test/7-tmq/tmq_taosx.py
+++ b/tests/system-test/7-tmq/tmq_taosx.py
@@ -653,7 +653,6 @@ class TDTestCase:
         self.checkSnapshot1VgroupTableBtmeta()
         self.checkSnapshotMultiVgroupsBtmeta()
         self.checkSnapshotMultiVgroupsWithDropTableBtmeta()
-        self.checkVgroupTable()
 
     def stop(self):
         tdSql.close()