From 3cc61aab6206a686e3386cb057581448f6e7fb30 Mon Sep 17 00:00:00 2001 From: chenyong152 Date: Fri, 12 Jul 2024 11:45:52 +0800 Subject: [PATCH] feat(wal):reduce concurrent conflicts between block write operations and poll operations (#1550) --- .../automq/stream/s3/wal/impl/block/SlidingWindowService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java b/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java index 1a534a900c..10809f0601 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java +++ b/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java @@ -61,11 +61,11 @@ public class SlidingWindowService { private final WALHeaderFlusher walHeaderFlusher; /** - * The lock of {@link #pendingBlocks}, {@link #writingBlocks}, {@link #currentBlock}. + * The lock of {@link #pendingBlocks}, {@link #currentBlock}. */ private final Lock blockLock = new ReentrantLock(); /** - * The lock of {@link #pendingBlocks}. + * The lock of {@link #pendingBlocks}, {@link #writingBlocks}. */ private final Lock pollBlockLock = new ReentrantLock(); /**