anoopsjohn commented on a change in pull request #2021:
URL: https://github.com/apache/hbase/pull/2021#discussion_r457306408
##########
File path:
hbase-server/src/main/java/org/apache/hadoop/hbase/wal/AbstractWALRoller.java
##########
@@ -249,4 +247,43 @@ public void close() {
running = false;
interrupt();
}
+
+ /**
+ * Independently control the roll of each wal. When use multiwal,
+ * can avoid all wal roll together. see HBASE-24665 for detail
+ */
+ protected class RollController {
+ private final WAL wal;
+ private final AtomicBoolean rollRequest;
+ private long lastRollTime;
+
+ RollController(WAL wal) {
+ this.wal = wal;
+ this.rollRequest = new AtomicBoolean(false);
+ this.lastRollTime = System.currentTimeMillis();
+ }
+
+ public void requestRoll() {
+ this.rollRequest.set(true);
+ }
+
+ public Map<byte[], List<byte[]>> rollWal(long now) throws IOException {
+ this.lastRollTime = now;
+ Map<byte[], List<byte[]>> regionsToFlush = wal.rollWriter(true);
+ this.rollRequest.set(false);
Review comment:
Sorry did not get. How AtomicBoolean is different compared to boolean
wrt repeated roll possibility. In the past we used to keep the Boolean state
in a Map. Now in this object.
----------------------------------------------------------------
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]
