fix: use abs of streamId

Signed-off-by: Ning Yu <[email protected]>
AutoMQ · Nov 25, 2023 · 5e3fa45 · 5e3fa45
1 parent 29f3972
commit 5e3fa45
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java b/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java
@@ -413,7 +413,7 @@ private void handleAppendCallback(WalWriteRequest request) {
     }
 
     private Lock getStreamCallbackLock(long streamId) {
-        return streamCallbackLocks[(int) (streamId % NUM_STREAM_CALLBACK_LOCKS)];
+        return streamCallbackLocks[(int) (Math.abs(streamId) % NUM_STREAM_CALLBACK_LOCKS)];
     }
 
     @SuppressWarnings("UnusedReturnValue")