diff --git a/source/client/src/clientStmt.c b/source/client/src/clientStmt.c index d3fc9bf327..2fbdc60a4e 100644 --- a/source/client/src/clientStmt.c +++ b/source/client/src/clientStmt.c @@ -14,6 +14,9 @@ static int32_t stmtCreateRequest(STscStmt* pStmt) { if (pStmt->exec.pRequest == NULL) { code = buildRequest(pStmt->taos->id, pStmt->sql.sqlStr, pStmt->sql.sqlLen, NULL, false, &pStmt->exec.pRequest, pStmt->reqid); + if (pStmt->reqid > 0) { + pStmt->reqid++; + } if (TSDB_CODE_SUCCESS == code) { pStmt->exec.pRequest->syncQuery = true; }