diff --git a/src/client/inc/tscBulkWrite.h b/src/client/inc/tscBulkWrite.h
index 92fcc19f22a43747db6d45191400ddd90f5e8a75..f83b9d33c429ecefa630b7db2c58f148f9a387b5 100644
--- a/src/client/inc/tscBulkWrite.h
+++ b/src/client/inc/tscBulkWrite.h
@@ -111,13 +111,13 @@ void destroyAsyncDispatcher(SAsyncBulkWriteDispatcher* dispatcher);
 bool tscSupportBulkInsertion(SAsyncBulkWriteDispatcher* dispatcher, SSqlObj* pSql);
 
 /**
- * Try to offer the SSqlObj* to the buffer. If the number of row reach `asyncBatchSize`, the function
+ * Try to offer the SSqlObj* to the dispatcher. If the number of row reach `batchSize`, the function
  * will merge the SSqlObj* in the buffer and send them to the vnodes.
  *
  * @param pSql the insert statement to offer.
  * @return     if offer success, returns true.
  */
-bool dispatcherTryBatching(SAsyncBulkWriteDispatcher* dispatcher, SSqlObj* pSql);
+bool dispatcherTryDispatch(SAsyncBulkWriteDispatcher* dispatcher, SSqlObj* pSql);
 
 /**
  * A holder of SAsyncBulkWriteDispatcher. Call dispatcherAcquire(...) to get the SAsyncBulkWriteDispatcher
diff --git a/src/client/src/tscAsync.c b/src/client/src/tscAsync.c
index 4d0d41a6e2ac0dad6f461ed56655d5a23a92558f..8e05ea73a52031e027186e19e30c457202670736 100644
--- a/src/client/src/tscAsync.c
+++ b/src/client/src/tscAsync.c
@@ -399,7 +399,7 @@ void doAsyncQuery(STscObj* pObj, SSqlObj* pSql, __async_cb_func_t fp, void* para
   
   if (tscDispatcher != NULL) {
     SAsyncBulkWriteDispatcher* dispatcher = dispatcherAcquire(tscDispatcher);
-    if (dispatcherTryBatching(dispatcher, pSql)) {
+    if (dispatcherTryDispatch(dispatcher, pSql)) {
       taosReleaseRef(tscObjRef, pSql->self);
       tscDebug("sql obj %p has been buffer in insert buffer", pSql);
       return;
diff --git a/src/client/src/tscBulkWrite.c b/src/client/src/tscBulkWrite.c
index 33bb37f0f382e8b863ddc42e2e89f1cecd48c2fb..ad03072cc578f84003c9278bd28f897ff6ecf635 100644
--- a/src/client/src/tscBulkWrite.c
+++ b/src/client/src/tscBulkWrite.c
@@ -445,7 +445,7 @@ bool tscSupportBulkInsertion(SAsyncBulkWriteDispatcher* dispatcher, SSqlObj* pSq
   return true;
 }
 
-bool dispatcherTryBatching(SAsyncBulkWriteDispatcher* dispatcher, SSqlObj* pSql) {
+bool dispatcherTryDispatch(SAsyncBulkWriteDispatcher* dispatcher, SSqlObj* pSql) {
   if (atomic_load_8(&dispatcher->shutdown)) {
     return false;
   }