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:05:41 +08:00
parent da9d4be816
commit e6041f381b
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnection.java
View File

@@ -584,10 +584,8 @@ public class MySQLConnection extends AbstractConnection implements BackendConnec
return;
}
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) {