hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From la...@apache.org
Subject svn commit: r1453064 - in /hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver: ReplicationHLogReaderManager.java ReplicationSource.java
Date Tue, 05 Mar 2013 22:49:45 GMT
Author: larsh
Date: Tue Mar  5 22:49:45 2013
New Revision: 1453064

URL: http://svn.apache.org/r1453064
Log:
HBASE-7944 Addendum (Jeffrey Zhong)

Modified:
    hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java
    hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java

Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java?rev=1453064&r1=1453063&r2=1453064&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java
(original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationHLogReaderManager.java
Tue Mar  5 22:49:45 2013
@@ -63,6 +63,7 @@ public class ReplicationHLogReaderManage
     // 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 = HLog.getReader(this.fs, path, this.conf);
       this.lastPath = path;
     } else {

Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1453064&r1=1453063&r2=1453064&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
(original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Tue Mar  5 22:49:45 2013
@@ -363,6 +363,7 @@ public class ReplicationSource extends T
         }
       } finally {
         try {
+          this.reader = null;
           this.repLogReader.closeReader();
         } catch (IOException e) {
           gotIOE = true;



Mime
View raw message