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 9f4177f7b4
commit c5461aaa5b
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); 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) {
sleepMultiplier ++; sleepMultiplier++;
} }
Threads.sleep(sleepForRetries * sleepMultiplier); Threads.sleep(sleepForRetries * sleepMultiplier);
} }