diff --git a/source/client/inc/clientStmt2.h b/source/client/inc/clientStmt2.h
index 74eb198930..4e9a09c082 100644
--- a/source/client/inc/clientStmt2.h
+++ b/source/client/inc/clientStmt2.h
@@ -150,10 +150,10 @@ typedef struct {
   SStmtExecInfo exec;
   SStmtBindInfo bInfo;
 
-  int64_t reqid;
-  int32_t errCode;
-  tsem_t  asyncQuerySem;
-
+  int64_t       reqid;
+  int32_t       errCode;
+  tsem_t        asyncQuerySem;
+  bool          semWaited;
   SStmtStatInfo stat;
 } STscStmt2;
 /*
diff --git a/source/client/src/clientMain.c b/source/client/src/clientMain.c
index a28c17cb25..7cfbeb1372 100644
--- a/source/client/src/clientMain.c
+++ b/source/client/src/clientMain.c
@@ -1984,8 +1984,9 @@ int taos_stmt2_bind_param(TAOS_STMT2 *stmt, TAOS_STMT2_BINDV *bindv, int32_t col
   }
 
   STscStmt2 *pStmt = (STscStmt2 *)stmt;
-  if (pStmt->options.asyncExecFn) {
+  if (pStmt->options.asyncExecFn && !pStmt->semWaited) {
     (void)tsem_wait(&pStmt->asyncQuerySem);
+    pStmt->semWaited = true;
   }
 
   int32_t code = 0;
diff --git a/source/client/src/clientStmt2.c b/source/client/src/clientStmt2.c
index 51533fc56c..1739dced8f 100644
--- a/source/client/src/clientStmt2.c
+++ b/source/client/src/clientStmt2.c
@@ -819,6 +819,7 @@ TAOS_STMT2* stmtInit2(STscObj* taos, TAOS_STMT2_OPTION* pOptions) {
   if (pStmt->options.asyncExecFn) {
     (void)tsem_init(&pStmt->asyncQuerySem, 0, 1);
   }
+  pStmt->semWaited = false;
 
   STMT_LOG_SEQ(STMT_INIT);
 
@@ -1678,6 +1679,7 @@ int stmtExec2(TAOS_STMT2* stmt, int* affected_rows) {
     pRequest->body.queryFp = asyncQueryCb;
     ((SSyncQueryParam*)(pRequest)->body.interParam)->userParam = pStmt;
 
+    pStmt->semWaited = false;
     launchAsyncQuery(pRequest, pStmt->sql.pQuery, NULL, pWrapper);
   }