You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2012/09/05 20:47:33 UTC
svn commit: r1381291 -
/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Author: stack
Date: Wed Sep 5 18:47:33 2012
New Revision: 1381291
URL: http://svn.apache.org/viewvc?rev=1381291&view=rev
Log:
HBASE-6649 [0.92 UNIT TESTS] TestReplication.queueFailover occasionally fails [Part-1]
Modified:
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Modified: hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1381291&r1=1381290&r2=1381291&view=diff
==============================================================================
--- hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (original)
+++ hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java Wed Sep 5 18:47:33 2012
@@ -428,7 +428,12 @@ public class ReplicationSource extends T
currentNbEntries >= this.replicationQueueNbCapacity) {
break;
}
- entry = this.reader.next(entriesArray[currentNbEntries]);
+ try {
+ entry = this.reader.next(entriesArray[currentNbEntries]);
+ } catch (IOException ie) {
+ LOG.debug("Break on IOE: " + ie.getMessage());
+ break;
+ }
}
LOG.debug("currentNbOperations:" + currentNbOperations +
" and seenEntries:" + seenEntries +