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 6068f23ace87..1b8562bab330 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 @@ -220,6 +220,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 (FileNotFoundException e) { // For now, this could happen only when reading meta wal for meta replicas. // In this case, raising UncheckedIOException will let the endpoint deal with resetting