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 02714cbc18
commit ad545aa548
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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