Skip to content

Commit a07faf0

Browse files
committed
code clean.
1 parent 9648be4 commit a07faf0

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java

+4-3
Original file line numberDiff line numberDiff line change
@@ -341,8 +341,8 @@ public ManagedLedgerImpl(ManagedLedgerFactoryImpl factory, BookKeeper bookKeeper
341341
}
342342
this.inactiveLedgerRollOverTimeMs = config.getInactiveLedgerRollOverTimeMs();
343343
this.managedTrash = config.isSupportTwoPhaseDeletion()
344-
? new ManagedTrashImpl(ManagedTrash.ManagedType.MANAGED_LEDGER, name, metadataStore, config, scheduledExecutor,
345-
executor, bookKeeper) : new ManagedTrashDisableImpl();
344+
? new ManagedTrashImpl(ManagedTrash.ManagedType.MANAGED_LEDGER, name, metadataStore, config,
345+
scheduledExecutor, executor, bookKeeper) : new ManagedTrashDisableImpl();
346346
}
347347

348348
synchronized void initialize(final ManagedLedgerInitializeLedgerCallback callback, final Object ctx) {
@@ -2688,7 +2688,8 @@ private CompletableFuture<?> asyncUpdateTrashData(Collection<Long> deletableLedg
26882688
managedTrash.appendLedgerTrashData(ledgerId, null, ManagedTrash.LedgerType.LEDGER);
26892689
}
26902690
for (Long ledgerId : deletableOffloadedLedgerIds) {
2691-
managedTrash.appendLedgerTrashData(ledgerId, ledgers.get(ledgerId), ManagedTrash.LedgerType.OFFLOAD_LEDGER);
2691+
managedTrash.appendLedgerTrashData(ledgerId, ledgers.get(ledgerId),
2692+
ManagedTrash.LedgerType.OFFLOAD_LEDGER);
26922693
}
26932694
future.complete(null);
26942695
} catch (ManagedLedgerException e) {

0 commit comments

Comments
 (0)