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
e2a00af843
commit
2d26c94ef0
@ -267,6 +267,7 @@ public class WALEntryStream implements Iterator<Entry>, Closeable, Iterable<Entr
|
|||||||
}
|
}
|
||||||
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