From 596f8d12acb6e2f6ddb8737338ae70cd47dfc890 Mon Sep 17 00:00:00 2001 From: Rushabh Shah Date: Tue, 14 Nov 2023 10:27:02 -0800 Subject: [PATCH] HBASE-28184 Addendum PR --- .../hbase/replication/regionserver/WALEntryStream.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 0a778cbb1b80..5acfa49c6193 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 @@ -259,10 +259,11 @@ private boolean readNextEntryAndRecordReaderPosition() throws IOException { Entry readEntry = reader.next(); long readerPos = reader.getPosition(); OptionalLong fileLength; - if (logQueue.getQueueSize(walGroupId) > 1) { + if (logQueue.getQueueSize(walGroupId) > 2) { fileLength = OptionalLong.empty(); } else { - // if there is only one file in queue, check whether it is still being written to + // if there are less than or equal 2 files in the queue, + // check whether it is still being written to. fileLength = walFileLengthProvider.getLogFileSizeIfBeingWritten(currentPath); } if (fileLength.isPresent() && readerPos > fileLength.getAsLong()) {