From 2d26c94ef082396bbcb557b8b360260f27d8cf79 Mon Sep 17 00:00:00 2001 From: Sandeep Pal <50725353+sandeepvinayak@users.noreply.github.com> Date: Wed, 17 Feb 2021 22:23:52 -0800 Subject: [PATCH] HBASE-25541 : Setting the path to null when we dequeue the current log (#2959) Signed-off-by: Bharath Vissapragada --- .../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 bed9c0fc76f1..7a440750f63d 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 @@ -267,6 +267,7 @@ private void dequeueCurrentLog() throws IOException { } closeReader(); logQueue.remove(); + setCurrentPath(null); setPosition(0); metrics.decrSizeOfLogQueue(); }