Skip to content

Commit 9a3c0d7

Browse files
committed
fix use backend connection information
1 parent 18add5e commit 9a3c0d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,7 @@ public void connectionClose(@NotNull AbstractService service, String reason) {
234234
loadDataClean();
235235
initDbClean();
236236
rwSplitService.getSession2().unbind();
237-
reason = "Connection {dbInstance[" + rwSplitService.getConnection().getHost() + ":" + rwSplitService.getConnection().getPort() + "],DbGroup[" +
237+
reason = "Connection {dbInstance[" + service.getConnection().getHost() + ":" + service.getConnection().getPort() + "],DbGroup[" +
238238
rwSplitService.getUserConfig().getDbGroup() + "],threadID[" +
239239
((MySQLResponseService) service).getConnection().getThreadId() + "]} was closed ,reason is [" + reason + "]";
240240
writeErrorMsg(rwSplitService.nextPacketId(), reason);

0 commit comments

Comments
 (0)