bench: fix KEYS

dtprj · Jun 11, 2024 · b56fbaa · b56fbaa
1 parent 75482e4
commit b56fbaa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/benchmark/src/main/java/com/github/dtprj/dongting/bench/raft/RaftBenchmark.java b/benchmark/src/main/java/com/github/dtprj/dongting/bench/raft/RaftBenchmark.java
@@ -199,7 +199,7 @@ public void shutdown() {
     public void test(int threadIndex, long startTime, int state) {
         try {
             int k = Integer.reverse((int) startTime);
-            k = k % KEYS;
+            k = Math.abs(k % KEYS);
             final DtTime timeout = new DtTime(800, TimeUnit.MILLISECONDS);
             CompletableFuture<Void> f = clients[threadIndex].put(GROUP_ID, String.valueOf(k), DATA, timeout);