Skip to content

Commit f391a50

Browse files
committed
fix(table_map_event_data_serializer): log a message when skipping deserializing the table map event
1 parent 3cb5fd5 commit f391a50

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,10 @@ public TableMapEventMetadata deserialize(ByteArrayInputStream inputStream, int n
5353
throw new IOException("Unsupported table metadata field type " + code);
5454

5555
//for some reasons, the UNKNOWN_METADATA_FIELD_TYPE will mess up the stream
56-
if(inputStream.available() == 0) return result;
56+
if(inputStream.available() == 0) {
57+
logger.warning("Stream is empty so cannot read field length for field type: " + fieldType);
58+
return result;
59+
}
5760

5861
int fieldLength = inputStream.readPackedInteger();
5962

0 commit comments

Comments
 (0)