From 3409472eb9b8d07c0c67f4b7af4ac746edf10e69 Mon Sep 17 00:00:00 2001 From: Chuanyi Li Date: Thu, 23 Nov 2017 22:25:47 +0800 Subject: [PATCH] kill CONNECTION exception fix revert. --- .../alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java | 3 ++- 1 file changed, 2 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 0e488162..bb8ec579 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 @@ -101,7 +101,8 @@ public class MysqlConnector { MysqlUpdateExecutor executor = new MysqlUpdateExecutor(connector); executor.update("KILL CONNECTION " + connectionId); } catch (Exception e) { - throw new IOException("KILL DUMP " + connectionId + " failure", e); + // 忽略具体异常 + logger.info("KILL DUMP " + connectionId + " failure", e); } finally { if (connector != null) { connector.disconnect();