diff --git a/source/libs/executor/src/executorimpl.c b/source/libs/executor/src/executorimpl.c
index a45b9d1fb4..86ed902d2c 100644
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@@ -7779,7 +7779,19 @@ SOperatorInfo* doCreateOperatorTreeNode(SPhyNode* pPhyNode, SExecTaskInfo* pTask
 
       SArray* pa = taosArrayGetP(groupInfo.pGroupList, 0);
       ASSERT(taosArrayGetSize(groupInfo.pGroupList) == 1);
-      return createStreamScanOperatorInfo(readerHandle, pPhyNode->pTargets, pa, pTaskInfo);
+      // Transfer the Array of STableKeyInfo into uid list.
+      size_t numOfTables = taosArrayGetSize(pa);
+      SArray* idList = taosArrayInit(numOfTables, sizeof(uint64_t));
+      for(int32_t i = 0; i < numOfTables; ++i) {
+        STableKeyInfo* pkeyInfo = taosArrayGet(pa, i);
+        taosArrayPush(idList, &pkeyInfo->uid);
+      }
+
+      SOperatorInfo* pOperator = createStreamScanOperatorInfo(readerHandle, pPhyNode->pTargets, idList, pTaskInfo);
+      taosArrayDestroy(idList);
+
+      //TODO destroy groupInfo
+      return pOperator;
     }
   }