Skip to content

Commit 3cc61aa

Browse files
committed
feat(wal):reduce concurrent conflicts between block write operations and poll operations (AutoMQ#1550)
1 parent 0847d72 commit 3cc61aa

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -61,11 +61,11 @@ public class SlidingWindowService {
6161
private final WALHeaderFlusher walHeaderFlusher;
6262

6363
/**
64-
* The lock of {@link #pendingBlocks}, {@link #writingBlocks}, {@link #currentBlock}.
64+
* The lock of {@link #pendingBlocks}, {@link #currentBlock}.
6565
*/
6666
private final Lock blockLock = new ReentrantLock();
6767
/**
68-
* The lock of {@link #pendingBlocks}.
68+
* The lock of {@link #pendingBlocks}, {@link #writingBlocks}.
6969
*/
7070
private final Lock pollBlockLock = new ReentrantLock();
7171
/**

0 commit comments

Comments
 (0)