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

fix npe inner 2232

Browse Source
This commit is contained in:
ylz
2023-06-28 10:11:10 +08:00
parent 99a899185e
commit 89ea3c79b9
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/backend/mysql/nio/MySQLConnection.java
View File

@@ -516,10 +516,9 @@ public class MySQLConnection extends AbstractConnection implements
public void signal() {
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) {