The GitHub Actions job "Build and Run Tests by Bazel" on 
rocketmq.git/cnj/example-randomasync-commit has failed.
Run started by GitHub user chennaji9 (triggered by chennaji9).

Head commit for run:
a04c99237203d87f951c7b7e0d2d8f3a4a6cd3a0 / 陈那几 <[email protected]>
[ISSUE #11281] fix(example): RandomAsyncCommit empty-cache exception and lost 
concurrent batch

commitableOffset called firstKey() on the cached TreeMap without an
emptiness check, so once every cached message was removed (or an empty
batch was cached) it threw NoSuchElementException instead of returning
the -1 sentinel. putMessages also initialized the per-queue cache with
get-then-put, letting two threads overwrite each other's CachedQueue and
lose a cached batch, and the inner TreeMap was read and written without
synchronization. Initialize with computeIfAbsent, synchronize the three
public methods, and return -1 when nothing is committable.

Co-Authored-By: Claude Opus 5 (1M context) <[email protected]>

Report URL: https://github.com/apache/rocketmq/actions/runs/36704849687

With regards,
GitHub Actions via GitBox

Reply via email to