diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 12ec7d4201..0cdb0e7954 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -3797,7 +3797,8 @@ FETCH_NEXT_BLOCK:
         code = setBlockGroupIdByUid(pInfo, pBlock);
         QUERY_CHECK_CODE(code, lino, _end);
 
-        deletePartName(pInfo, pBlock);
+        code = deletePartName(pInfo, pBlock);
+        QUERY_CHECK_CODE(code, lino, _end);
         goto FETCH_NEXT_BLOCK;
       } break;
       case STREAM_CHECKPOINT: {