Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-25992 Addendum add missing catch WALEntryFilterRetryableException back

This commit is contained in:
Duo Zhang 2021-06-21 23:57:37 +08:00
parent 41a68325c2
commit 12d707c880
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
View File

@ -155,11 +155,11 @@ class ReplicationSourceWALReader extends Thread {
entryBatchQueue.put(batch);
sleepMultiplier = 1;
}
} catch (IOException e) { // stream related
} catch (WALEntryFilterRetryableException | IOException e) { // stream related
if (!handleEofException(e, batch)) {
LOG.warn("Failed to read stream of replication entries", e);
if (sleepMultiplier < maxRetriesMultiplier) {
sleepMultiplier ++;
sleepMultiplier++;
}
Threads.sleep(sleepForRetries * sleepMultiplier);
}