From 77998988960f0ab4a286909b54ad6e543f17c678 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Mon, 14 Oct 2024 19:40:55 +0800
Subject: [PATCH] fix(stream): adj result flag

---
 source/libs/executor/src/streamtimesliceoperator.c | 6 +++---
 source/libs/stream/src/streamSliceState.c          | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/source/libs/executor/src/streamtimesliceoperator.c b/source/libs/executor/src/streamtimesliceoperator.c
index f55d76c2e9..57643d29e8 100644
--- a/source/libs/executor/src/streamtimesliceoperator.c
+++ b/source/libs/executor/src/streamtimesliceoperator.c
@@ -1836,6 +1836,8 @@ static int32_t doStreamTimeSliceNext(SOperatorInfo* pOperator, SSDataBlock** ppR
   }
 
   initMultiResInfoFromArrayList(&pInfo->groupResInfo, pInfo->pUpdated);
+  pInfo->groupResInfo.freeItem = false;
+
   pInfo->pUpdated = taosArrayInit(16, sizeof(SWinKey));
   QUERY_CHECK_NULL(pInfo->pUpdated, code, lino, _end, terrno);
 
@@ -2023,6 +2025,7 @@ int32_t createStreamTimeSliceOperatorInfo(SOperatorInfo* downstream, SPhysiNode*
   }
 
   int32_t keyBytes = sizeof(TSKEY);
+  keyBytes += blockDataGetRowSize(pDownRes) + sizeof(SResultCellData) * taosArrayGetSize(pDownRes->pDataBlock);
   if (pPkCol) {
     keyBytes += pPkCol->bytes;
   }
@@ -2073,9 +2076,6 @@ int32_t createStreamTimeSliceOperatorInfo(SOperatorInfo* downstream, SPhysiNode*
     pInfo->isHistoryOp = pHandle->fillHistory;
   }
 
-  // init Info->groupResInfo
-  pInfo->groupResInfo.freeItem = false;
-
   pOperator->operatorType = QUERY_NODE_PHYSICAL_PLAN_STREAM_INTERP_FUNC;
   setOperatorInfo(pOperator, getStreamOpName(pOperator->operatorType), QUERY_NODE_PHYSICAL_PLAN_STREAM_INTERP_FUNC,
                   true, OP_NOT_OPENED, pInfo, pTaskInfo);
diff --git a/source/libs/stream/src/streamSliceState.c b/source/libs/stream/src/streamSliceState.c
index c92fac5968..ec451274ab 100644
--- a/source/libs/stream/src/streamSliceState.c
+++ b/source/libs/stream/src/streamSliceState.c
@@ -237,7 +237,7 @@ int32_t getHashSortPrevRow(SStreamFileState* pFileState, const SWinKey* pKey, SW
   if (ppBuff) {
     pWinStates = (SArray*)(*ppBuff);
   } else {
-    qTrace("===stream=== search buff is empty.group id:%" PRId64, pKey->groupId);
+    qDebug("===stream=== search buff is empty.group id:%" PRId64, pKey->groupId);
     SStreamStateCur* pCur = streamStateFillSeekKeyPrev_rocksdb(pState, pKey);
     void*            tmpVal = NULL;
     int32_t          len = 0;