Respond to PR feedback

Ahmed Abdul Hamid · Ahmed Abdul Hamid · commit fb5fe1b0ff98 · 2019-02-06T00:44:39.000-08:00
diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventDataDeserializer.java b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventDataDeserializer.java
@@ -40,7 +40,8 @@ public TableMapEventData deserialize(ByteArrayInputStream inputStream) throws IO
         inputStream.readPackedInteger(); // metadata length
         eventData.setColumnMetadata(readMetadata(inputStream, eventData.getColumnTypes()));
         eventData.setColumnNullability(inputStream.readBitSet(numberOfColumns, true));
-        eventData.setEventMetadata(metadataDeserializer.deserialize(inputStream, numberOfColumns));
+        eventData.setEventMetadata(metadataDeserializer.deserialize(
+            new ByteArrayInputStream(inputStream.read(inputStream.available())), numberOfColumns));
         return eventData;
     }
 
diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java
@@ -82,8 +82,6 @@ public TableMapEventMetadata deserialize(ByteArrayInputStream inputStream, int n
                     result.setEnumAndSetColumnCharsets(readIntegers(inputStream));
                     break;
                 default:
-                    // set the remaining bytes before throwing so the main event deserializer
-                    // knows how many bytes to skip in order to skip this entire Table Map event
                     inputStream.enterBlock(remainingBytes);
                     throw new IOException("Unsupported table metadata field type " + fieldType);
             }

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,8 @@ public TableMapEventData deserialize(ByteArrayInputStream inputStream) throws IO`
`40`	`40`	`inputStream.readPackedInteger(); // metadata length`
`41`	`41`	`eventData.setColumnMetadata(readMetadata(inputStream, eventData.getColumnTypes()));`
`42`	`42`	`eventData.setColumnNullability(inputStream.readBitSet(numberOfColumns, true));`
`43`		`- eventData.setEventMetadata(metadataDeserializer.deserialize(inputStream, numberOfColumns));`
	`43`	`+ eventData.setEventMetadata(metadataDeserializer.deserialize(`
	`44`	`+ new ByteArrayInputStream(inputStream.read(inputStream.available())), numberOfColumns));`
`44`	`45`	`return eventData;`
`45`	`46`	`}`
`46`	`47`
Original file line number	Diff line number	Diff line change
`@@ -82,8 +82,6 @@ public TableMapEventMetadata deserialize(ByteArrayInputStream inputStream, int n`
`82`	`82`	`result.setEnumAndSetColumnCharsets(readIntegers(inputStream));`
`83`	`83`	`break;`
`84`	`84`	`default:`
`85`		`- // set the remaining bytes before throwing so the main event deserializer`
`86`		`- // knows how many bytes to skip in order to skip this entire Table Map event`
`87`	`85`	`inputStream.enterBlock(remainingBytes);`
`88`	`86`	`throw new IOException("Unsupported table metadata field type " + fieldType);`
`89`	`87`	`}`