From c16037122b9f4b1a3961f8b1cef4bd169b7c932e Mon Sep 17 00:00:00 2001 From: winger Date: Fri, 19 Oct 2018 10:27:50 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=80=9A=E8=BF=87`show=20mas?= =?UTF-8?q?ter=20status`=E8=8E=B7=E5=8F=96=E5=88=B0=E5=A4=9A=E4=B8=AAGTID?= =?UTF-8?q?=20=E6=97=B6=EF=BC=8C=E5=9B=9E=E8=BD=A6=E7=AC=A6=E5=AF=BC?= =?UTF-8?q?=E8=87=B4UUID=20=E8=A7=A3=E6=9E=90=E5=A4=B1=E8=B4=A5=E7=9A=84bu?= =?UTF-8?q?g?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/parse/driver/mysql/packets/MysqlGTIDSet.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MysqlGTIDSet.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MysqlGTIDSet.java index 35872370..f5128e23 100644 --- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MysqlGTIDSet.java +++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MysqlGTIDSet.java @@ -86,7 +86,8 @@ public class MysqlGTIDSet implements GTIDSet { if (gtidData == null || gtidData.length() < 1) { m = new HashMap(); } else { - String[] uuidStrs = gtidData.split(","); + // 存在多个GTID时会有回车符 + String[] uuidStrs = gtidData.replaceAll("\n", "").split(","); m = new HashMap(uuidStrs.length); for (int i = 0; i < uuidStrs.length; i++) { UUIDSet uuidSet = UUIDSet.parse(uuidStrs[i]);