You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2024/01/09 23:38:22 UTC
(pulsar) branch branch-2.10 updated: [fix] [ml] Fix retry mechanism of deleting ledgers to invalidate (#21869)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.10 by this push:
new 2770de006cf [fix] [ml] Fix retry mechanism of deleting ledgers to invalidate (#21869)
2770de006cf is described below
commit 2770de006cf276dee5f8bebfe2a6ca3b59aa49b3
Author: fengyubiao <yu...@streamnative.io>
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 35108fea175..c2239953c50 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) -> {