From a7da41cbc0c51c1ce0530b94c9a5ccb4f8dd29d5 Mon Sep 17 00:00:00 2001 From: winteen Date: Wed, 1 Apr 2015 10:27:11 +0800 Subject: [PATCH] fix EventHeaderV4Deserializer type bug --- .../binlog/event/deserialization/EventHeaderV4Deserializer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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;