Skip to content

Commit fb69813

Browse files
committed
fixed mariadb 10.x
1 parent c055737 commit fb69813

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,7 @@ public abstract class LogEvent {
229229
public static final int DELETE_ROWS_COMPRESSED_EVENT = 171;
230230

231231
/** end marker */
232-
public static final int ENUM_END_EVENT = 165;
232+
public static final int ENUM_END_EVENT = 171;
233233

234234
/**
235235
* 1 byte length, 1 byte format Length is total length in bytes, including 2

dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -711,6 +711,7 @@ private final void unpackVariables(LogBuffer buffer, final int end) throws IOExc
711711
case Q_XID:
712712
// xid= uint8korr(pos);
713713
buffer.forward(8);
714+
break;
714715
case Q_GTID_FLAGS3:
715716
// gtid_flags_extra= *pos++;
716717
// 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
725726
if ((gtid_flags_extra & (FL_COMMIT_ALTER_E1 | FL_ROLLBACK_ALTER_E1))> 0) {
726727
buffer.forward(8);
727728
}
729+
break;
728730
default:
729731
/*
730732
* That's why you must write status vars in growing

0 commit comments

Comments
 (0)