diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
index 6f2856663a8..ca411848077 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
@@ -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);
         }