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(); /**