HBASE-6649 [0.92 UNIT TESTS] TestReplication.queueFailover occasional…

…ly fails [Part-1] git-svn-id: https://svn.apache.org/repos/asf/hbase/branches/0.94@1381289 13f79535-47bb-0310-9956-ffa450edef68
StumbleUponArchive · Sep 5, 2012 · 62df7bc · 62df7bc
1 parent b42895e
commit 62df7bc
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java b/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
@@ -425,7 +425,12 @@ protected boolean readAllEntriesToReplicateOrNextFile() throws IOException{
           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 +