This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d9f0f28c33279f0230800658ea7de0c469b05007 Author: Yunze Xu <[email protected]> AuthorDate: Mon Jan 20 22:08:08 2025 +0800 [improve][broker] Remove spamming logs for customized managed ledger (#23862) (cherry picked from commit a93e93dddddc3751a2d29727fc5226b689fed204) --- .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java index 56aeb9b4a5e..0f508445958 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java @@ -3494,8 +3494,8 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal TopicName topicName = TopicName.get(getName()); if (!(ledger.getCursors() instanceof ManagedCursorContainer managedCursorContainer)) { - return CompletableFuture.failedFuture(new IllegalStateException( - String.format("[%s] No valid cursors found. Skip update old position info.", topicName))); + // TODO: support this method with a customized managed ledger implementation + return CompletableFuture.completedFuture(null); } if (!hasBacklogs(brokerService.pulsar().getConfiguration().isPreciseTimeBasedBacklogQuotaCheck())) {
