diff --git a/src/main/java/com/actiontech/dble/net/connection/AbstractConnection.java b/src/main/java/com/actiontech/dble/net/connection/AbstractConnection.java
index c3a1bb874..ab5c638ca 100644
--- a/src/main/java/com/actiontech/dble/net/connection/AbstractConnection.java
+++ b/src/main/java/com/actiontech/dble/net/connection/AbstractConnection.java
@@ -338,7 +338,7 @@ public abstract class AbstractConnection implements Connection {
             if (buffer != null) {
                 recycle(buffer);
             }
-            this.cleanup(null);
+            this.cleanup("it will not writeDirectly because connection has been closed.");
             return;
         }
 
diff --git a/src/main/java/com/actiontech/dble/net/connection/BackendConnection.java b/src/main/java/com/actiontech/dble/net/connection/BackendConnection.java
index 81c03388b..0e8df0517 100644
--- a/src/main/java/com/actiontech/dble/net/connection/BackendConnection.java
+++ b/src/main/java/com/actiontech/dble/net/connection/BackendConnection.java
@@ -30,6 +30,7 @@ public class BackendConnection extends PooledConnection {
         super(channel, socketWR);
         this.instance = instance;
         DbInstanceConfig config = instance.getConfig();
+        this.connectionTimeout = config.getPoolConfig().getConnectionTimeout();
         this.host = config.getIp();
         this.port = config.getPort();
         this.lastTime = TimeUtil.currentTimeMillis();