Skip to content

Commit 6362f65

Browse files
committed
Fix transaction payload event deserialization
1 parent 68bb199 commit 6362f65

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TransactionPayloadEventDataDeserializer.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -154,10 +154,9 @@ public TransactionPayloadEventData deserialize(BinaryLogEventDataReader eventDat
154154
EventDeserializer transactionPayloadEventDeserializer = new EventDeserializer();
155155
BinaryLogEventDataReader decompressedReader = new BinaryLogEventDataReader(dst);
156156

157-
Event internalEvent = transactionPayloadEventDeserializer.deserializeEvent(decompressedReader);
158-
while (internalEvent != null) {
157+
while (decompressedReader.available() > 0) {
158+
Event internalEvent = transactionPayloadEventDeserializer.deserializeEvent(decompressedReader);
159159
decompressedEvents.add(internalEvent);
160-
internalEvent = transactionPayloadEventDeserializer.deserializeEvent(decompressedReader);
161160
}
162161

163162
eventData.setUncompressedEvents(decompressedEvents);

0 commit comments

Comments
 (0)