[fix][broker] Fix markDeletedPosition race condition in ManagedLedgerImpl.maybeUpdateCursorBeforeTrimmingConsumedLedger() method - #25110

Merged

BewareMyPower merged 28 commits into

apache:masterfrom

oneby-wang:maybeUpdateCursorBeforeTrimmingConsumedLedger_mark_delete

Jan 12, 2026

Commits on Jan 9, 2026

[fix][broker] Fix markDeletedPosition race condition in maybeUpdateCursorBeforeTrimmingConsumedLedger
oneby-wang
committed
c4a48bb
[fix][broker] Add debug log
oneby-wang
committed
732264f
[fix][broker] Wait updating cursor finished when opening managed ledger
oneby-wang
committed
1d34d97
[fix][broker] Modify uncorrected comment
oneby-wang
committed
e3812ca
[fix][broker] Add test for maybeUpdateCursorBeforeTrimmingConsumedLedger
oneby-wang
committed
aa25bcb
[fix][broker] Fix test
oneby-wang
committed
7d03b0a
[fix][broker] Fix test
oneby-wang
committed
93b0255
[fix][test] Rollback some codes for test
oneby-wang
committed
40932eb
[fix][broker] Try to fix maybeUpdateCursorBeforeTrimmingConsumedLedger method
oneby-wang
committed
892a372
[fix][broker] Fix race condition in ManagedCursorImpl.getNumberOfEntries
oneby-wang
committed
15ec22e
[fix][broker] Fix CompactionTest.testCompactorReadsCompacted
oneby-wang
committed
33b327d
[fix][broker] Fix race condition in ManagedCursorImpl.getNumberOfEntries
oneby-wang
committed
6f4b2fe
[fix][broker] Fix ManagedCursorTest.testFlushCursorAfterError test
oneby-wang
committed
33cb384
[fix][broker] Modify logic
oneby-wang
committed
f320c55
[fix][broker] Fix ManagedCursorTest testFlushCursorAfterInactivity and testFlushCursorAfterIndividualDeleteInactivity test
oneby-wang
committed
4b73a15
[fix][broker] Fix ManagedCursorTest.testLazyCursorLedgerCreation test
oneby-wang
committed
3d1bb13
[fix][broker] Fix ManagedCursorTest.testPersistentMarkDeleteIfCreateCursorLedgerFailed test
oneby-wang
committed
87b25c6
[fix][broker] Fix ManagedCursorTest.testPersistentMarkDeleteIfSwitchCursorLedgerFailed test
oneby-wang
committed
d7b1f6a
[fix][broker] Fix tests
oneby-wang
committed
e52772d
[fix][broker] Fix some flaky assert in ManagedLedgerTest.testTrimmerRaceCondition
oneby-wang
committed
16deef7
[fix][broker] Remove some flaky asserts in ManagedLedgerTest.testTrimmerRaceCondition
oneby-wang
committed
6475bca
[fix][broker] Try to fix race condition when setting mark delete properties in ManagedLedgerTest.testTrimmerRaceCondition
oneby-wang
committed
0589f5a
[fix][broker] Support null mark delete properties in NonDurableCursorImpl.internalAsyncMarkDelete
oneby-wang
committed
bd62af6
[fix][broker] Rollback CompactionTest.testCompactorReadsCompacted test
oneby-wang
committed
4cb9046
[fix][broker] Add ManagedLedgerTest.testTrimmerRaceConditionInNonDurableCursor test
oneby-wang
committed
1399578
[fix][broker] Fix race condition in ManagedCursorImpl.updateLastMarkDeleteEntryToLatest, add test
oneby-wang
committed
925b3ed
[fix][broker] Fix checkstyle
oneby-wang
committed
df9ac29

Commits on Jan 12, 2026

[fix][broker] Add markDeletePosition assert in testTrimmerRaceConditionWithThrottleMarkDeleteInDurableCursor
oneby-wang
committed
3f88653

Navigation Menu

[fix][broker] Fix markDeletedPosition race condition in ManagedLedgerImpl.maybeUpdateCursorBeforeTrimmingConsumedLedger() method - #25110

[fix][broker] Fix markDeletedPosition race condition in ManagedLedgerImpl.maybeUpdateCursorBeforeTrimmingConsumedLedger() method#25110
BewareMyPower merged 28 commits into
apache:masterfrom
oneby-wang:maybeUpdateCursorBeforeTrimmingConsumedLedger_mark_delete

Commits on Jan 9, 2026

[fix][broker] Fix markDeletedPosition race condition in maybeUpdateCursorBeforeTrimmingConsumedLedger

[fix][broker] Add debug log

[fix][broker] Wait updating cursor finished when opening managed ledger

[fix][broker] Modify uncorrected comment

[fix][broker] Add test for maybeUpdateCursorBeforeTrimmingConsumedLedger

[fix][broker] Fix test

[fix][broker] Fix test

[fix][test] Rollback some codes for test

[fix][broker] Try to fix maybeUpdateCursorBeforeTrimmingConsumedLedger method

[fix][broker] Fix race condition in ManagedCursorImpl.getNumberOfEntries

[fix][broker] Fix CompactionTest.testCompactorReadsCompacted

[fix][broker] Fix race condition in ManagedCursorImpl.getNumberOfEntries

[fix][broker] Fix ManagedCursorTest.testFlushCursorAfterError test

[fix][broker] Modify logic

[fix][broker] Fix ManagedCursorTest testFlushCursorAfterInactivity and testFlushCursorAfterIndividualDeleteInactivity test

[fix][broker] Fix ManagedCursorTest.testLazyCursorLedgerCreation test

[fix][broker] Fix ManagedCursorTest.testPersistentMarkDeleteIfCreateCursorLedgerFailed test

[fix][broker] Fix ManagedCursorTest.testPersistentMarkDeleteIfSwitchCursorLedgerFailed test

[fix][broker] Fix tests

[fix][broker] Fix some flaky assert in ManagedLedgerTest.testTrimmerRaceCondition

[fix][broker] Remove some flaky asserts in ManagedLedgerTest.testTrimmerRaceCondition

[fix][broker] Try to fix race condition when setting mark delete properties in ManagedLedgerTest.testTrimmerRaceCondition

[fix][broker] Support null mark delete properties in NonDurableCursorImpl.internalAsyncMarkDelete

[fix][broker] Rollback CompactionTest.testCompactorReadsCompacted test

[fix][broker] Add ManagedLedgerTest.testTrimmerRaceConditionInNonDurableCursor test

[fix][broker] Fix race condition in ManagedCursorImpl.updateLastMarkDeleteEntryToLatest, add test

[fix][broker] Fix checkstyle

Commits on Jan 12, 2026

[fix][broker] Add markDeletePosition assert in testTrimmerRaceConditionWithThrottleMarkDeleteInDurableCursor