From afa7d04aaf67d9d0305d13ab4be0edac63b4efa1 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 18 Jul 2024 16:39:01 +0800
Subject: [PATCH] adj stream operator result

---
 source/libs/executor/src/groupoperator.c    | 2 +-
 source/libs/stream/src/streamSessionState.c | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/groupoperator.c b/source/libs/executor/src/groupoperator.c
index 2e65ca2a7a..58228cb2e5 100644
--- a/source/libs/executor/src/groupoperator.c
+++ b/source/libs/executor/src/groupoperator.c
@@ -1374,7 +1374,7 @@ static SSDataBlock* doStreamHashPartition(SOperatorInfo* pOperator) {
   pInfo->pTbNameIte = taosHashIterate(pInfo->pPartitions, NULL);
   code = buildStreamCreateTableResult(pOperator);
   TSDB_CHECK_CODE(code, lino, _end);
-  if (pInfo->pCreateTbRes->info.rows > 0) {
+  if (pInfo->pCreateTbRes && pInfo->pCreateTbRes->info.rows > 0) {
     return pInfo->pCreateTbRes;
   }
   return buildStreamPartitionResult(pOperator);
diff --git a/source/libs/stream/src/streamSessionState.c b/source/libs/stream/src/streamSessionState.c
index dd63dc6115..c20f6b0577 100644
--- a/source/libs/stream/src/streamSessionState.c
+++ b/source/libs/stream/src/streamSessionState.c
@@ -713,6 +713,7 @@ int32_t sessionWinStateGetKVByCur(SStreamStateCur* pCur, SSessionKey* pKey, void
       if (!pNewPos || !pNewPos->pRowBuff) {
         code = TSDB_CODE_OUT_OF_MEMORY;
         taosMemoryFreeClear(pData);
+        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
         return code;
       }
       memcpy(pNewPos->pKey, pKey, sizeof(SSessionKey));