diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java index 80804051a0af5a..511189409658e9 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java @@ -341,8 +341,8 @@ public ManagedLedgerImpl(ManagedLedgerFactoryImpl factory, BookKeeper bookKeeper } this.inactiveLedgerRollOverTimeMs = config.getInactiveLedgerRollOverTimeMs(); this.managedTrash = config.isSupportTwoPhaseDeletion() - ? new ManagedTrashImpl(ManagedTrash.ManagedType.MANAGED_LEDGER, name, metadataStore, config, scheduledExecutor, - executor, bookKeeper) : new ManagedTrashDisableImpl(); + ? new ManagedTrashImpl(ManagedTrash.ManagedType.MANAGED_LEDGER, name, metadataStore, config, + scheduledExecutor, executor, bookKeeper) : new ManagedTrashDisableImpl(); } synchronized void initialize(final ManagedLedgerInitializeLedgerCallback callback, final Object ctx) { @@ -2688,7 +2688,8 @@ private CompletableFuture asyncUpdateTrashData(Collection deletableLedg managedTrash.appendLedgerTrashData(ledgerId, null, ManagedTrash.LedgerType.LEDGER); } for (Long ledgerId : deletableOffloadedLedgerIds) { - managedTrash.appendLedgerTrashData(ledgerId, ledgers.get(ledgerId), ManagedTrash.LedgerType.OFFLOAD_LEDGER); + managedTrash.appendLedgerTrashData(ledgerId, ledgers.get(ledgerId), + ManagedTrash.LedgerType.OFFLOAD_LEDGER); } future.complete(null); } catch (ManagedLedgerException e) {