Skip to content

Commit ddca7ea

Browse files
author
Stanley Shyiko
committed
Updated TableMapEventDataDeserializer (shyiko#251)
1 parent c43e4ea commit ddca7ea

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

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

+10-2
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
package com.github.shyiko.mysql.binlog.event.deserialization;
1717

1818
import com.github.shyiko.mysql.binlog.event.TableMapEventData;
19+
import com.github.shyiko.mysql.binlog.event.TableMapEventMetadata;
1920
import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
2021

2122
import java.io.IOException;
@@ -40,8 +41,15 @@ public TableMapEventData deserialize(ByteArrayInputStream inputStream) throws IO
4041
inputStream.readPackedInteger(); // metadata length
4142
eventData.setColumnMetadata(readMetadata(inputStream, eventData.getColumnTypes()));
4243
eventData.setColumnNullability(inputStream.readBitSet(numberOfColumns, true));
43-
eventData.setEventMetadata(metadataDeserializer.deserialize(
44-
new ByteArrayInputStream(inputStream.read(inputStream.available())), numberOfColumns));
44+
int metadataLength = inputStream.available();
45+
TableMapEventMetadata metadata = null;
46+
if (metadataLength > 0) {
47+
metadata = metadataDeserializer.deserialize(
48+
new ByteArrayInputStream(inputStream.read(metadataLength)),
49+
numberOfColumns
50+
);
51+
}
52+
eventData.setEventMetadata(metadata);
4553
return eventData;
4654
}
4755

0 commit comments

Comments
 (0)