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]);