diff --git a/src/common/src/tdataformat.c b/src/common/src/tdataformat.c
index 2578f33246bc416e93ada6e442ae27741f3f4253..c34a049a417f5e9bd460cc167b0c08665fef4d49 100644
--- a/src/common/src/tdataformat.c
+++ b/src/common/src/tdataformat.c
@@ -489,7 +489,9 @@ static void tdAppendDataRowToDataCol(SDataRow row, STSchema *pSchema, SDataCols
       dcol++;
     }
   }
-  pCols->numOfRows++;
+  if (rowOffset == 0) {
+    ++pCols->numOfRows;
+  }
 }
 
 static void tdAppendKvRowToDataCol(SKVRow row, STSchema *pSchema, SDataCols *pCols, bool forceSetNull, int rowOffset) {
@@ -526,7 +528,9 @@ static void tdAppendKvRowToDataCol(SKVRow row, STSchema *pSchema, SDataCols *pCo
       ++dcol;
     }
   }
-  pCols->numOfRows++;
+  if (rowOffset == 0) {
+    ++pCols->numOfRows;
+  }
 }
 
 void tdAppendMemRowToDataCol(SMemRow row, STSchema *pSchema, SDataCols *pCols, bool forceSetNull, int rowOffset) {