From 623203490ad4d063806a2f457c3c81022535e5fe Mon Sep 17 00:00:00 2001 From: Cary Xu Date: Mon, 1 Nov 2021 15:25:25 +0800 Subject: [PATCH] [TS-549]:fix numOfRows for update 2 --- src/common/src/tdataformat.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/common/src/tdataformat.c b/src/common/src/tdataformat.c index 2578f33246..c34a049a41 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) { -- GitLab