HBASE-25992 Addendum add missing catch WALEntryFilterRetryableExcepti…

…on back
apache · Jun 21, 2021 · c5461aa · c5461aa
1 parent 9f4177f
commit c5461aa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ain/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java b/...ain/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
@@ -155,11 +155,11 @@ public void run() {
           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);
         }