From ef11316340b56e40be9b73df906afe159925a30a Mon Sep 17 00:00:00 2001
From: Charles Connell <cconnell@hubspot.com>
Date: Sat, 15 Jun 2024 09:00:02 -0400
Subject: [PATCH] In WALEntryStream, always use current WALTailingReader if one
 exists

---
 .../hadoop/hbase/replication/regionserver/WALEntryStream.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 186d5b7c4d18..8d74d0e0399e 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -219,6 +219,7 @@ private HasNext prepareReader() {
             // we will read from the beginning so we should always clear the compression context
             reader.resetTo(-1, true);
           }
+          return HasNext.YES;
         } catch (IOException e) {
           LOG.warn("Failed to reset reader {} to pos {}, reset compression={}", currentPath,
             currentPositionOfEntry, state.resetCompression(), e);