From e6041f381b7beecd2e010deadd018f8c9127f471 Mon Sep 17 00:00:00 2001
From: ylz <yuanlinzhu1995@gmail.com>
Date: Wed, 28 Jun 2023 10:05:41 +0800
Subject: [PATCH] fix npe  inner 2232

---
 .../actiontech/dble/backend/mysql/nio/MySQLConnection.java  | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnection.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnection.java
index e32d3b775..595984cd0 100644
--- a/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnection.java
+++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnection.java
@@ -584,10 +584,8 @@ public class MySQLConnection extends AbstractConnection implements BackendConnec
             return;
         }
         this.setFlowControlled(false);
-        if (recycler != null) {
-            recycler.signal();
-            recycler = null;
-        }
+        Optional.ofNullable(recycler).ifPresent(res -> res.signal());
+        recycler = null;
     }
 
     private String getSetSQL(Map<String, String> usrVars, Map<String, String> sysVars, Set<String> toResetSys) {