diff --git a/source/libs/executor/src/projectoperator.c b/source/libs/executor/src/projectoperator.c
index 8ab0efbacf..1cc377b3ee 100644
--- a/source/libs/executor/src/projectoperator.c
+++ b/source/libs/executor/src/projectoperator.c
@@ -665,7 +665,7 @@ int32_t doGenerateSourceData(SOperatorInfo* pOperator) {
 
         int32_t startOffset = pRes->info.rows;
         ASSERT(pRes->info.capacity > 0);
-        colDataMergeCol(pResColData, startOffset, (int32_t*)&pRes->info.capacity, &idata, dest.numOfRows);
+        colDataAssign(pResColData, &idata, dest.numOfRows, &pRes->info);
         colDataDestroy(&idata);
 
         taosArrayDestroy(pBlockList);