You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2013/03/05 23:49:45 UTC
svn commit: r1453064 - in
/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver:
ReplicationHLogReaderManager.java ReplicationSource.java
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;