diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 7822aa9711..095d7e1a2b 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -3486,10 +3486,11 @@ void streamScanOperatorDecode(void* pBuff, int32_t len, SStreamScanInfo* pInfo)
   if (code == TSDB_CODE_SUCCESS) {
     pInfo->stateStore.updateInfoDestroy(pInfo->pUpdateInfo);
     pInfo->pUpdateInfo = pUpInfo;
+    qDebug("%s line:%d. stream scan updateinfo deserialize success", __func__, __LINE__);
   } else {
     taosMemoryFree(pUpInfo);
-    lino = __LINE__;
-    goto _end;
+    code = TSDB_CODE_SUCCESS;
+    qDebug("%s line:%d. stream scan did not have updateinfo", __func__, __LINE__);
   }
 
   if (tDecodeIsEnd(pDeCoder)) {
diff --git a/source/libs/stream/src/streamUpdate.c b/source/libs/stream/src/streamUpdate.c
index ff11850d7c..49d5041369 100644
--- a/source/libs/stream/src/streamUpdate.c
+++ b/source/libs/stream/src/streamUpdate.c
@@ -449,6 +449,7 @@ int32_t updateInfoSerialize(SEncoder* pEncoder, const SUpdateInfo* pInfo) {
       code = TSDB_CODE_FAILED;
       QUERY_CHECK_CODE(code, lino, _end);
     }
+    uDebug("%s line:%d. it did not have updateinfo", __func__, __LINE__);
     return TSDB_CODE_SUCCESS;
   }