From 7a3f1afe68939b05477ba02063bc8105527176e4 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Fri, 18 Oct 2024 16:08:22 +0800
Subject: [PATCH] fix issue

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

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 32012c9fbb..392cb8f5c7 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -3436,7 +3436,7 @@ void streamScanOperatorDecode(void* pBuff, int32_t len, SStreamScanInfo* pInfo)
   SDecoder decoder = {0};
   pDeCoder = &decoder;
   tDecoderInit(pDeCoder, buf, tlen);
-  if (tStartDecode(&decoder) < 0) {
+  if (tStartDecode(pDeCoder) < 0) {
     lino = __LINE__;
     goto _end;
   }
@@ -4316,6 +4316,10 @@ void streamScanReloadState(SOperatorInfo* pOperator) {
   SDecoder decoder = {0};
   pDeCoder = &decoder;
   tDecoderInit(pDeCoder, pBuff, len);
+  if (tStartDecode(pDeCoder) < 0) {
+    lino = __LINE__;
+    goto _end;
+  }
   int32_t winCode = pInfo->stateStore.updateInfoDeserialize(pDeCoder, pUpInfo);
   taosMemoryFree(pBuff);
   if (winCode == TSDB_CODE_SUCCESS && pInfo->pUpdateInfo) {