chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

renew an InetSocketAddress to resolve address again

Browse Source 
resolve [issue427](https://github.com/alibaba/otter/issues/427)
This commit is contained in:
whaon
2018-03-14 09:55:20 +08:00
committed by GitHub
parent 499be8bd8c
commit 256056e14f
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java
View File

@@ -50,7 +50,10 @@ public class MysqlConnector {
} }
public MysqlConnector(InetSocketAddress address, String username, String password){ public MysqlConnector(InetSocketAddress address, String username, String password){
this.address = address; String addr = address.getHostString();
int port = address.getPort();
this.address = new InetSocketAddress(addr, port);
this.username = username; this.username = username;
this.password = password; this.password = password;
} }