HBASE-6649 [0.92 UNIT TESTS] TestReplication.queueFailover occasionally fails [Part-1]
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1381287 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
09719846b3
commit
ebae97fc60
@ -430,7 +430,12 @@ public class ReplicationSource extends Thread
|
|||||||
currentNbEntries >= this.replicationQueueNbCapacity) {
|
currentNbEntries >= this.replicationQueueNbCapacity) {
|
||||||
break;
|
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 +
|
LOG.debug("currentNbOperations:" + currentNbOperations +
|
||||||
" and seenEntries:" + seenEntries +
|
" and seenEntries:" + seenEntries +
|
||||||
|
Loading…
x
Reference in New Issue
Block a user