diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c
index aa9204e62af95e9025eb0c65c32b9a26223ca548..b03972bbfa2fc8f98251529c79bdbb88357b6cc1 100644
--- a/src/client/src/tscParseInsert.c
+++ b/src/client/src/tscParseInsert.c
@@ -1321,7 +1321,6 @@ int tsParseSql(SSqlObj *pSql, bool initialParse) {
   int32_t ret = TSDB_CODE_SUCCESS;
   SSqlCmd* pCmd = &pSql->cmd;
 
-  tscTrace("------------------%p, initial:%d, sqlstr:%s", pSql, initialParse, pSql->sqlstr);
   if (!pCmd->parseFinished) {
     tscTrace("%p resume to parse sql: %s", pSql, pCmd->curSql);
   }
diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index bb57da86fd066985108ce2f053854ce0cfb77470..5faa515d40ffe1929922e25700a2d4e95c951b93 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -1853,18 +1853,17 @@ static void multiVnodeInsertFinalize(void* param, TAOS_RES* tres, int numOfRows)
   SSubqueryState* pState = pSupporter->pState;
 
   // record the total inserted rows
-  if (numOfRows > 0) {
-    if (tres != pParentObj) {
+  if (numOfRows > 0 && tres != pParentObj) {
       pParentObj->res.numOfRows += numOfRows;
-    }
-  } else {
+  }
+
+  if (taos_errno(tres) != 0) {
     SSqlObj* pSql = (SSqlObj*) tres;
     assert(pSql != NULL && pSql->res.code == numOfRows);
     
     pParentObj->res.code = pSql->res.code;
   }
 
-
   // it is not the initial sqlObj, free it
   if (tres != pParentObj) {
     taos_free_result(tres);