From ecf8f92ac833f8379f021d61e16680480d076f82 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Tue, 5 Nov 2024 11:11:23 +0800
Subject: [PATCH] fix ci issue

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

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index e75a9d59a4..5135c368b3 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2134,7 +2134,8 @@ static int32_t generateSessionScanRange(SStreamScanInfo* pInfo, SSDataBlock* pSr
     if (tSimpleHashGet(pScanRange, &checkKey, sizeof(SSessionKey)) != NULL) {
       continue;
     }
-    tSimpleHashPut(pScanRange, &checkKey, sizeof(SSessionKey), NULL, 0);
+    code = tSimpleHashPut(pScanRange, &checkKey, sizeof(SSessionKey), NULL, 0);
+    QUERY_CHECK_CODE(code, lino, _end);
 
     code = colDataSetVal(pDestStartCol, i, (const char*)&startWin.win.skey, false);
     QUERY_CHECK_CODE(code, lino, _end);
@@ -2310,7 +2311,8 @@ static int32_t generateIntervalScanRange(SStreamScanInfo* pInfo, SSDataBlock* pS
     if (tSimpleHashGet(pScanRange, &checkKey, sizeof(SSessionKey)) != NULL) {
       continue;
     }
-    tSimpleHashPut(pScanRange, &checkKey, sizeof(SSessionKey), NULL, 0);
+    code = tSimpleHashPut(pScanRange, &checkKey, sizeof(SSessionKey), NULL, 0);
+    QUERY_CHECK_CODE(code, lino, _end);
 
     code = colDataSetVal(pStartTsCol, pDestBlock->info.rows, (const char*)(&win.skey), false);
     QUERY_CHECK_CODE(code, lino, _end);