mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-04-30 03:21:14 -05: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 b3585f19f3
commit 01faaa7864
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java
+1 -1
View File
@@ -224,7 +224,7 @@ public class RWSplitHandler implements ResponseHandler, LoadDataResponseHandler,
loadDataClean();
initDbClean();
rwSplitService.getSession2().unbind();
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);