From ac3c76f60895023168689eb9adfca9eb02f402c2 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Mon, 25 Dec 2023 19:38:20 +0800
Subject: [PATCH] init dummy function

---
 .../executor/src/streamtimewindowoperator.c   |  4 +++
 tests/script/tsim/stream/session1.sim         | 36 +++++++++++++++++++
 2 files changed, 40 insertions(+)

diff --git a/source/libs/executor/src/streamtimewindowoperator.c b/source/libs/executor/src/streamtimewindowoperator.c
index 7b68b65c17..c9490e2c55 100644
--- a/source/libs/executor/src/streamtimewindowoperator.c
+++ b/source/libs/executor/src/streamtimewindowoperator.c
@@ -1623,6 +1623,7 @@ void initDummyFunction(SqlFunctionCtx* pDummy, SqlFunctionCtx* pCtx, int32_t num
     pDummy[i].functionId = pCtx[i].functionId;
     pDummy[i].isNotNullFunc = pCtx[i].isNotNullFunc;
     pDummy[i].isPseudoFunc = pCtx[i].isPseudoFunc;
+    pDummy[i].fpSet.init = pCtx[i].fpSet.init;
   }
 }
 
@@ -2774,6 +2775,9 @@ void streamSessionSemiReloadState(SOperatorInfo* pOperator) {
   for (int32_t i = 0; i < num; i++) {
     SResultWindowInfo winInfo = {0};
     getSessionWindowInfoByKey(pAggSup, pSeKeyBuf + i, &winInfo);
+    if (!IS_VALID_SESSION_WIN(winInfo)) {
+      continue;
+    }
     compactSessionSemiWindow(pOperator, &winInfo);
     saveSessionOutputBuf(pAggSup, &winInfo);
   }
diff --git a/tests/script/tsim/stream/session1.sim b/tests/script/tsim/stream/session1.sim
index cf42159d84..aae17053b2 100644
--- a/tests/script/tsim/stream/session1.sim
+++ b/tests/script/tsim/stream/session1.sim
@@ -327,4 +327,40 @@ if $rows != 1 then
   goto loop17
 endi
 
+sql create database test2  vgroups 4;
+sql use test2;
+sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+sql create stream streams4 trigger at_once ignore update 0 ignore expired 0 into streamt4 as select  _wstart, count(*) c1, count(a) c2  from st session(ts, 2s) ;
+
+sql insert into t1 values(1648791255100,1,2,3);
+sql insert into t1 values(1648791255300,1,2,3);
+
+sleep 1000
+
+sql insert into t1 values(1648791253000,1,2,3) (1648791254000,1,2,3);
+
+$loop_count = 0
+loop18:
+sleep 1000
+sql select * from streamt4;
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+if $rows != 1 then
+  print =====rows=$rows
+  goto loop18
+endi
+
+if $data01 != 4 then
+  print =====data01=$data01
+  goto loop18
+endi
+
+print =====over
+
 system sh/exec.sh -n dnode1 -s stop -x SIGINT