From 267c704ae740a607484b936607229561da8ae9cd Mon Sep 17 00:00:00 2001 From: Sandeep Pal Date: Tue, 16 Feb 2021 10:06:04 -0800 Subject: [PATCH] Setting the path to null when we dequeue the current log --- .../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 a95ee13c7379..a2da1eca50ed 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 @@ -252,6 +252,7 @@ private void dequeueCurrentLog() throws IOException { LOG.debug("EOF, closing {}", currentPath); closeReader(); logQueue.remove(); + setCurrentPath(null); setPosition(0); metrics.decrSizeOfLogQueue(); }