init dummy function

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);
   }

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