Browse Source

Merge pull request #555 from whaon/patch-1

renew an InetSocketAddress to resolve address again
agapple 7 years ago
parent
commit
6229a8593f

+ 4 - 1
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java

@@ -50,7 +50,10 @@ public class MysqlConnector {
     }
 
     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.password = password;
     }