diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c
index 125af9749a8b29433405507209c531aff1a0906b..2811c8dce84918bc61339597150b15f56690b99d 100644
--- a/source/libs/executor/src/executor.c
+++ b/source/libs/executor/src/executor.c
@@ -169,13 +169,9 @@ int32_t qUpdateQualifiedTableId(qTaskInfo_t tinfo, const SArray* tableIdList, bo
     qDebug(" %d qualified child tables added into stream scanner", (int32_t)taosArrayGetSize(qa));
     code = tqReadHandleAddTbUidList(pScanInfo->streamBlockReader, qa);
     taosArrayDestroy(qa);
-
   } else {  // remove the table id in current list
-    SArray* qa = filterQualifiedChildTables(pScanInfo, tableIdList);
-
     qDebug(" %d remove child tables from the stream scanner", (int32_t)taosArrayGetSize(tableIdList));
-    code = tqReadHandleAddTbUidList(pScanInfo->streamBlockReader, tableIdList);
-    taosArrayDestroy(qa);
+    code = tqReadHandleRemoveTbUidList(pScanInfo->streamBlockReader, tableIdList);
   }
 
   return code;