diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/FileLogFetcher.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/FileLogFetcher.java index dce0ee6b..d35ffcb0 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/FileLogFetcher.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/FileLogFetcher.java @@ -129,11 +129,11 @@ public final class FileLogFetcher extends LogFetcher { } } else if (limit > 0) { System.arraycopy(buffer, origin, buffer, 0, limit); + position -= origin; + origin = 0; final int len = fin.read(buffer, limit, buffer.length - limit); if (len >= 0) { limit += len; - position -= origin; - origin = 0; /* More binlog to fetch */ return true;