diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java index 698381852e..ace5f2fdac 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java @@ -229,7 +229,7 @@ public abstract class LogEvent { public static final int DELETE_ROWS_COMPRESSED_EVENT = 171; /** end marker */ - public static final int ENUM_END_EVENT = 165; + public static final int ENUM_END_EVENT = 171; /** * 1 byte length, 1 byte format Length is total length in bytes, including 2 diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java index cf5f0c1e77..e617ccc178 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java @@ -711,6 +711,7 @@ private final void unpackVariables(LogBuffer buffer, final int end) throws IOExc case Q_XID: // xid= uint8korr(pos); buffer.forward(8); + break; case Q_GTID_FLAGS3: // gtid_flags_extra= *pos++; // if (gtid_flags_extra & (Gtid_log_event::FL_COMMIT_ALTER_E1 | @@ -725,6 +726,7 @@ private final void unpackVariables(LogBuffer buffer, final int end) throws IOExc if ((gtid_flags_extra & (FL_COMMIT_ALTER_E1 | FL_ROLLBACK_ALTER_E1))> 0) { buffer.forward(8); } + break; default: /* * That's why you must write status vars in growing