diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java b/src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java index 20807056..11ae79cf 100644 --- a/src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java +++ b/src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java @@ -33,7 +33,7 @@ public enum EventType { */ START_V3, /** - * Represents query statement. + * Written when an updating statement is done. */ QUERY, /** diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java index a3384df5..2d8bcdd8 100644 --- a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java +++ b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java @@ -34,7 +34,7 @@ public EventHeaderV4 deserialize(ByteArrayInputStream inputStream) throws IOExce header.setTimestamp(inputStream.readLong(4) * 1000L); header.setEventType(getEventType(inputStream.readInteger(1))); header.setServerId(inputStream.readLong(4)); - header.setEventLength(inputStream.readInteger(4)); + header.setEventLength(inputStream.readLong(4)); header.setNextPosition(inputStream.readLong(4)); header.setFlags(inputStream.readInteger(2)); return header;