HBASE-7944 Addendum (Jeffrey Zhong)

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1453059 13f79535-47bb-0310-9956-ffa450edef68

hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java

@@ -64,6 +64,7 @@ public class ReplicationHLogReaderManager {
     // Detect if this is a new file, if so get a new reader else
     // reset the current reader so that we see the new data
     if (this.reader == null || !this.lastPath.equals(path)) {
+      this.closeReader();
       this.reader = HLogFactory.createReader(this.fs, path, this.conf);
       this.lastPath = path;
     } else {

hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java

@@ -365,6 +365,7 @@ public class ReplicationSource extends Thread
         }
       } finally {
         try {
+          this.reader = null;
           this.repLogReader.closeReader();
         } catch (IOException e) {
           gotIOE = true;