[TS-549]<fix>:fix numOfRows for update 2

62320349 · Cary Xu · f58eac88 · 62320349
显示空白变更内容
内联并排

Showing with 6 addition and 2 deletion

src/common/src/tdataformat.c src/common/src/tdataformat.c +6 -2

未找到文件。
--- 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) {