diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index 0ede6f9b2db41cdb37e7d18a6be612a272cf042c..65e16eb618357fcfb2948dddbe3048e78b4f0135 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1094,7 +1094,7 @@ static void cliSendBatchCb(uv_write_t* req, int status) {
   } else {
     tDebug("%s conn %p succ to send batch msg, batch size:%d, msgLen:%d", CONN_GET_INST_LABEL(conn), conn, p->wLen,
            p->batchSize);
-    if (conn->broken != true) {
+    if (!uv_is_closing((uv_handle_t*)&conn->stream)) {
       if (nxtBatch != NULL) {
         conn->pBatch = nxtBatch;
         cliSendBatch(conn);