diff --git a/src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java b/src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java
index 608b92e31..5dc0fc018 100644
--- a/src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java
+++ b/src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java
@@ -215,7 +215,7 @@ public class RWSplitHandler implements ResponseHandler, LoadDataResponseHandler,
         synchronized (this) {
             if (!write2Client) {
                 rwSplitService.getSession().bind(null);
-                reason = "Connection {dbInstance[" + rwSplitService.getConnection().getHost() + ":" + rwSplitService.getConnection().getPort() + "],DbGroup[" +
+                reason = "Connection {dbInstance[" + service.getConnection().getHost() + ":" + service.getConnection().getPort() + "],DbGroup[" +
                         rwSplitService.getUserConfig().getDbGroup() + "],threadID[" +
                         ((MySQLResponseService) service).getConnection().getThreadId() + "]} was closed ,reason is [" + reason + "]";
                 writeErrorMsg(rwSplitService.nextPacketId(), reason);