diff --git a/source/libs/executor/src/projectoperator.c b/source/libs/executor/src/projectoperator.c
index 5a54da6535a701a385a67b1e45a05c757c2a1067..cd9bbbbb02fc91d79559e181351152e3adbe51b2 100644
--- a/source/libs/executor/src/projectoperator.c
+++ b/source/libs/executor/src/projectoperator.c
@@ -650,7 +650,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);