Skip to content

Commit b86ff6f

Browse files
committed
Fix typo in TIMESTAMP_V2 fractional seconds decoder
1 parent cf999ce commit b86ff6f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ private java.util.Date deserializeDatetimeV2(int meta, ByteArrayInputStream inpu
267267
private int getFractionalSeconds(int meta, ByteArrayInputStream inputStream) throws IOException {
268268
int fractionalSecondsStorageSize = getFractionalSecondsStorageSize(meta);
269269
if (fractionalSecondsStorageSize > 0) {
270-
long fractionalSeconds = bigEndianLong(inputStream.read(meta), 0, meta);
270+
long fractionalSeconds = bigEndianLong(inputStream.read(fractionalSecondsStorageSize), 0, fractionalSecondsStorageSize);
271271
if (meta % 2 == 1) {
272272
fractionalSeconds /= 10;
273273
}

0 commit comments

Comments
 (0)