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

fix npe inner 2232

Browse Source
This commit is contained in:
ylz
2023-06-28 10:23:02 +08:00
parent 1fc85e560d
commit 437709b10e
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

@@ -562,10 +562,9 @@ public class MySQLConnection extends AbstractConnection implements
}
this.setRowDataFlowing(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) {