commit 1beda0d598f4be4afb303a976c96b5471ebf9cf8
author Sandeep Pal <50725353+sandeepvinayak@users.noreply.github.com> Wed Feb 17 22:23:52 2021 -0800
committer GitHub <noreply@github.com> Thu Feb 18 11:53:52 2021 +0530
tree 856e8817c91ee5b62d21cc2dc3111703b11959a2
parent 618236dd9040625cf38a4d98338ccff8ab35bfec

HBASE-25541 : Setting the path to null when we dequeue the current log (#2959)

Signed-off-by: Bharath Vissapragada <bharathv@apache.org>

hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java

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 a95ee13..a2da1ec 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 @@
     LOG.debug("EOF, closing {}", currentPath);
     closeReader();
     logQueue.remove();
+    setCurrentPath(null);
     setPosition(0);
     metrics.decrSizeOfLogQueue();
   }