From f43915b74ef7f0ad7c0f0718c80fe368cbff5a23 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 25 Jul 2024 08:54:48 +0800
Subject: [PATCH] fix issue

---
 source/libs/executor/src/streameventwindowoperator.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/streameventwindowoperator.c b/source/libs/executor/src/streameventwindowoperator.c
index 1181b1d981..728ac317d4 100644
--- a/source/libs/executor/src/streameventwindowoperator.c
+++ b/source/libs/executor/src/streameventwindowoperator.c
@@ -591,7 +591,7 @@ static int32_t doStreamEventAggNext(SOperatorInfo* pOperator, SSDataBlock** ppRe
   SStreamEventAggOperatorInfo* pInfo = pOperator->info;
   SOptrBasicInfo*              pBInfo = &pInfo->binfo;
   SExecTaskInfo*               pTaskInfo = pOperator->pTaskInfo;
-  qDebug("===stream=== stream event agg");
+  qDebug("===stream=== stream event agg. history task:%d, taskId:%s", pInfo->isHistoryOp, GET_TASKID(pTaskInfo));
   if (pOperator->status == OP_RES_TO_RETURN) {
     SSDataBlock* resBlock = NULL;
     code = buildEventResult(pOperator, &resBlock);
@@ -692,6 +692,10 @@ static int32_t doStreamEventAggNext(SOperatorInfo* pOperator, SSDataBlock** ppRe
     code = copyUpdateResult(&pInfo->pAllUpdated, pHisWins, sessionKeyCompareAsc);
     QUERY_CHECK_CODE(code, lino, _end);
 
+    _hash_fn_t hashFn = taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY);
+    pInfo->pAllUpdated = tSimpleHashInit(64, hashFn);
+    QUERY_CHECK_NULL(pInfo->pAllUpdated, code, lino, _end, TSDB_CODE_OUT_OF_MEMORY);
+
     code = getMaxTsWins(pHisWins, pInfo->historyWins);
     QUERY_CHECK_CODE(code, lino, _end);