We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f0e177d commit 465dfdeCopy full SHA for 465dfde
src/main/java/com/actiontech/dble/services/BackendService.java
@@ -335,10 +335,8 @@ public void backendSpecialCleanUp() {
335
336
public void releaseSignal() {
337
isRowDataFlowing = false;
338
- if (recycler != null) {
339
- recycler.signal();
340
- recycler = null;
341
- }
+ Optional.ofNullable(recycler).ifPresent(res -> res.signal());
+ recycler = null;
342
}
343
344
public void resetContextStatus() {
0 commit comments