HBASE-25541 : Setting the path to null when we dequeue the current log (#2959)
Signed-off-by: Bharath Vissapragada <bharathv@apache.org>
This commit is contained in:
parent
d784e3f177
commit
ec680c52e0
@ -252,6 +252,7 @@ class WALEntryStream implements Closeable {
|
|||||||
LOG.debug("EOF, closing {}", currentPath);
|
LOG.debug("EOF, closing {}", currentPath);
|
||||||
closeReader();
|
closeReader();
|
||||||
logQueue.remove();
|
logQueue.remove();
|
||||||
|
setCurrentPath(null);
|
||||||
setPosition(0);
|
setPosition(0);
|
||||||
metrics.decrSizeOfLogQueue();
|
metrics.decrSizeOfLogQueue();
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user