joshelser commented on a change in pull request #2191:
URL: https://github.com/apache/hbase/pull/2191#discussion_r469395639
##########
File path:
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
##########
@@ -309,6 +310,16 @@ public WALEntryBatch poll(long timeout) throws
InterruptedException {
return entryBatchQueue.poll(timeout, TimeUnit.MILLISECONDS);
}
+ public void clearWALEntryBatch() {
Review comment:
> after we certify that neither the shipper, nor the reader threads are
alive anymore, so I don't think it would be an issue. Of course, there's the
risk someone inadvertently call this method somewhere else, so maybe we should
put a warning comment?
Also OK to just put a warning if moving this check doesn't make things more
clear :). Thanks for clarifying for me.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
