diff --git src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java index ce8585c..ae5c3bd 100644 --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java @@ -122,6 +122,7 @@ public class ReplicationHLogReaderManager { public void closeReader() throws IOException { if (this.reader != null) { this.reader.close(); + this.reader = null; } } @@ -130,7 +131,11 @@ public class ReplicationHLogReaderManager { */ public void finishCurrentFile() { this.position = 0; - this.reader = null; + try { + this.closeReader(); + } catch (IOException e) { + LOG.warn("Unable to close reader", e); + } } } diff --git src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java index 304c5a2..138dfd2 100644 --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java @@ -325,6 +325,7 @@ public class ReplicationSource extends Thread } boolean gotIOE = false; + currentNbOperations = 0; currentNbEntries = 0; currentSize = 0; try {