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

fix use backend connection information

Browse Source
This commit is contained in:
ylz
2023-06-02 15:36:26 +08:00
parent 73b6631c9d
commit 13f8560ea8
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java
View File

@@ -215,7 +215,7 @@ public class RWSplitHandler implements ResponseHandler, LoadDataResponseHandler,
synchronized (this) {
if (!write2Client) {
rwSplitService.getSession().bind(null);
reason = "Connection {dbInstance[" + rwSplitService.getConnection().getHost() + ":" + rwSplitService.getConnection().getPort() + "],DbGroup[" +
reason = "Connection {dbInstance[" + service.getConnection().getHost() + ":" + service.getConnection().getPort() + "],DbGroup[" +
rwSplitService.getUserConfig().getDbGroup() + "],threadID[" +
((MySQLResponseService) service).getConnection().getThreadId() + "]} was closed ,reason is [" + reason + "]";
writeErrorMsg(rwSplitService.nextPacketId(), reason);