From 256056e14fb12abae0f50952d8646db05adbfd29 Mon Sep 17 00:00:00 2001 From: whaon Date: Wed, 14 Mar 2018 09:55:20 +0800 Subject: [PATCH] renew an InetSocketAddress to resolve address again resolve [issue427](https://github.com/alibaba/otter/issues/427) --- .../otter/canal/parse/driver/mysql/MysqlConnector.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java index 5d407112..a8e6305a 100644 --- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java +++ b/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; }