Merge pull request #5103 from taosdata/hotfix/TD-2902

[TD-2902]Insert affectedRows is not correct with multiple vnodes

Merge pull request #5103 from taosdata/hotfix/TD-2902
[TD-2902]Insert affectedRows is not correct with multiple vnodes
9777218e · haojun Liao · GitHub · f23cc290 · 7fba734b · 9777218e
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

src/client/src/tscSubquery.c src/client/src/tscSubquery.c +1 -1

未找到文件。
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2410,7 +2410,7 @@ static void multiVnodeInsertFinalize(void* param, TAOS_RES* tres, int numOfRows)

  // record the total inserted rows
  if (numOfRows > 0) {
-    pParentObj->res.numOfRows += numOfRows;
+    atomic_add_fetch_32(&pParentObj->res.numOfRows, numOfRows);
  }

  if (taos_errno(tres) != TSDB_CODE_SUCCESS) {