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:46:38 UTC
svn commit: r1381287 -
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Author: stack
Date: Wed Sep 5 18:46:38 2012
New Revision: 1381287
URL: http://svn.apache.org/viewvc?rev=1381287&view=rev
Log:
HBASE-6649 [0.92 UNIT TESTS] TestReplication.queueFailover occasionally fails [Part-1]
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1381287&r1=1381286&r2=1381287&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java Wed Sep 5 18:46:38 2012
@@ -430,7 +430,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 +