fix(wal/benchmark): append at a fixed rate

Signed-off-by: Ning Yu <[email protected]>
AutoMQ · Nov 14, 2023 · de3a8a3 · de3a8a3
1 parent 6d60a43
commit de3a8a3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/benchmark/WriteBench.java b/s3stream/src/main/java/com/automq/stream/s3/wal/benchmark/WriteBench.java
@@ -138,7 +138,7 @@ private void runAppendTask(int index, AppendTaskConfig config, Stat stat) throws
                 long now = System.nanoTime();
                 long elapsedNanos = now - lastAppendTimeNanos;
                 if (elapsedNanos >= intervalNanos) {
-                    lastAppendTimeNanos = now;
+                    lastAppendTimeNanos += intervalNanos;
                     break;
                 }
                 LockSupport.parkNanos((intervalNanos - elapsedNanos) >> 2);