This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new ab7b3eff43e [fix] [ml] Fix retry mechanism of deleting ledgers to
invalidate (#21869)
ab7b3eff43e is described below
commit ab7b3eff43e4a44bcddaf6cc3a8bac5d0cf74d09
Author: fengyubiao <[email protected]>
AuthorDate: Wed Jan 10 07:31:04 2024 +0800
[fix] [ml] Fix retry mechanism of deleting ledgers to invalidate (#21869)
---
.../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 796c07df2f7..4a021085f9c 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
@@ -3114,7 +3114,7 @@ public class ManagedLedgerImpl implements ManagedLedger,
CreateCallback {
.thenCompose(readHandle ->
config.getLedgerOffloader().offload(readHandle, uuid, extraMetadata))
.thenCompose((ignore) -> {
return
Retries.run(Backoff.exponentialJittered(TimeUnit.SECONDS.toMillis(1),
-
TimeUnit.SECONDS.toHours(1)).limit(10),
+
TimeUnit.HOURS.toMillis(1)).limit(10),
FAIL_ON_CONFLICT,
() ->
completeLedgerInfoForOffloaded(ledgerId, uuid),
scheduledExecutor, name)
@@ -3337,7 +3337,7 @@ public class ManagedLedgerImpl implements ManagedLedger,
CreateCallback {
metadataMap.putAll(offloadDriverMetadata);
metadataMap.put("ManagedLedgerName", name);
- Retries.run(Backoff.exponentialJittered(TimeUnit.SECONDS.toMillis(1),
TimeUnit.SECONDS.toHours(1)).limit(10),
+ Retries.run(Backoff.exponentialJittered(TimeUnit.SECONDS.toMillis(1),
TimeUnit.HOURS.toMillis(1)).limit(10),
Retries.NonFatalPredicate,
() -> config.getLedgerOffloader().deleteOffloaded(ledgerId,
uuid, metadataMap),
scheduledExecutor, name).whenComplete((ignored, exception) -> {
