mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-06 04:40:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3753 from actiontech/22222

Browse Source 
fix npe  inner 2232
This commit is contained in:
ylinzhu
2023-06-27 14:17:28 +08:00
committed by GitHub
parent 13f8560ea8 df48a4d4bd
commit b98b9b8b58
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java
View File

@@ -716,10 +716,9 @@ public class MySQLResponseService extends VariablesService {
public void signal() {
this.setRowDataFlowing(false);
if (recycler != null) {
recycler.signal();
recycler = null;
}
Optional.ofNullable(recycler).ifPresent(res -> res.signal());
recycler = null;
}