Merge pull request #3732 from actiontech/2232

fix npe inner 2232
actiontech · Jun 16, 2023 · 9399679 · 9399679
2 parents f0e177d + 465dfde
commit 9399679
Showing 1 changed file with 2 additions and 4 deletions.
diff --git 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 void backendSpecialCleanUp() {
 
     public void releaseSignal() {
         isRowDataFlowing = false;
-        if (recycler != null) {
-            recycler.signal();
-            recycler = null;
-        }
+        Optional.ofNullable(recycler).ifPresent(res -> res.signal());
+        recycler = null;
     }
 
     public void resetContextStatus() {