From 3cfda2c5794072d2e1c9d199cf03fd9ef6914fb3 Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Tue, 20 Jun 2023 17:44:41 +0800
Subject: [PATCH] scan op transform

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

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 0e68b8d0a6..db9c384776 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2320,6 +2320,9 @@ static void destroyStreamScanOperatorInfo(void* param) {
 
 void streamScanReleaseState(SOperatorInfo* pOperator) {
   SStreamScanInfo* pInfo = pOperator->info;
+  if (!pInfo->pState) {
+    return;
+  }
   if (!pInfo->pUpdateInfo) {
     return;
   }
@@ -2331,6 +2334,9 @@ void streamScanReleaseState(SOperatorInfo* pOperator) {
 
 void streamScanReloadState(SOperatorInfo* pOperator) {
   SStreamScanInfo* pInfo = pOperator->info;
+  if (!pInfo->pState) {
+    return;
+  }
   void*   pBuff = NULL;
   int32_t len = 0;
   pInfo->stateStore.streamStateGetInfo(pInfo->pState, STREAM_SCAN_OP_STATE_NAME, strlen(STREAM_SCAN_OP_STATE_NAME), &pBuff, &len);