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

Merged

BewareMyPower merged 28 commits intoapache: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
[fix][broker] Add debug log
oneby-wang
committed
[fix][broker] Wait updating cursor finished when opening managed ledger
oneby-wang
committed
[fix][broker] Modify uncorrected comment
oneby-wang
committed
[fix][broker] Add test for maybeUpdateCursorBeforeTrimmingConsumedLedger
oneby-wang
committed
[fix][broker] Fix test
oneby-wang
committed
[fix][broker] Fix test
oneby-wang
committed
[fix][test] Rollback some codes for test
oneby-wang
committed
[fix][broker] Try to fix maybeUpdateCursorBeforeTrimmingConsumedLedger method
oneby-wang
committed
[fix][broker] Fix race condition in ManagedCursorImpl.getNumberOfEntries
oneby-wang
committed
[fix][broker] Fix CompactionTest.testCompactorReadsCompacted
oneby-wang
committed
[fix][broker] Fix race condition in ManagedCursorImpl.getNumberOfEntries
oneby-wang
committed
[fix][broker] Fix ManagedCursorTest.testFlushCursorAfterError test
oneby-wang
committed
[fix][broker] Modify logic
oneby-wang
committed
[fix][broker] Fix ManagedCursorTest testFlushCursorAfterInactivity and testFlushCursorAfterIndividualDeleteInactivity test
oneby-wang
committed
[fix][broker] Fix ManagedCursorTest.testLazyCursorLedgerCreation test
oneby-wang
committed
[fix][broker] Fix ManagedCursorTest.testPersistentMarkDeleteIfCreateCursorLedgerFailed test
oneby-wang
committed
[fix][broker] Fix ManagedCursorTest.testPersistentMarkDeleteIfSwitchCursorLedgerFailed test
oneby-wang
committed
[fix][broker] Fix tests
oneby-wang
committed
[fix][broker] Fix some flaky assert in ManagedLedgerTest.testTrimmerRaceCondition
oneby-wang
committed
[fix][broker] Remove some flaky asserts in ManagedLedgerTest.testTrimmerRaceCondition
oneby-wang
committed
[fix][broker] Try to fix race condition when setting mark delete properties in ManagedLedgerTest.testTrimmerRaceCondition
oneby-wang
committed
[fix][broker] Support null mark delete properties in NonDurableCursorImpl.internalAsyncMarkDelete
oneby-wang
committed
[fix][broker] Rollback CompactionTest.testCompactorReadsCompacted test
oneby-wang
committed
[fix][broker] Add ManagedLedgerTest.testTrimmerRaceConditionInNonDurableCursor test
oneby-wang
committed
[fix][broker] Fix race condition in ManagedCursorImpl.updateLastMarkDeleteEntryToLatest, add test
oneby-wang
committed
[fix][broker] Fix checkstyle
oneby-wang
committed

Commits on Jan 12, 2026

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

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[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 intoapache: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