GeorgeJahad commented on code in PR #4621:
URL: https://github.com/apache/ozone/pull/4621#discussion_r1181916572
##########
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerStateMachine.java:
##########
@@ -718,4 +718,7 @@ public long getTermForIndex(long transactionIndex) {
return applyTransactionMap.get(transactionIndex);
}
+ public void awaitDoubleBufferFlush() throws InterruptedException {
Review Comment:
No, it will be used by the tarball creation code. That code will first
block the deletion service, (which is my next pr.) Then call this method to
wait until the buffers are cleared. That way we can be sure that no moveKey
operations from the deletion service are waiting in the buffers
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
