From 465dfde0782d98ef9d72e3d6c51c155f5c802a01 Mon Sep 17 00:00:00 2001
From: ylz <yuanlinzhu1995@gmail.com>
Date: Tue, 13 Jun 2023 10:32:03 +0800
Subject: [PATCH] fix npe  inner 2232

---
 .../java/com/actiontech/dble/services/BackendService.java   | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/actiontech/dble/services/BackendService.java b/src/main/java/com/actiontech/dble/services/BackendService.java
index 15fe03f1f..f6bd1b1c9 100644
--- a/src/main/java/com/actiontech/dble/services/BackendService.java
+++ b/src/main/java/com/actiontech/dble/services/BackendService.java
@@ -335,10 +335,8 @@ public abstract class BackendService extends AbstractService {
 
     public void releaseSignal() {
         isRowDataFlowing = false;
-        if (recycler != null) {
-            recycler.signal();
-            recycler = null;
-        }
+        Optional.ofNullable(recycler).ifPresent(res -> res.signal());
+        recycler = null;
     }
 
     public void resetContextStatus() {