From a06f3367871844acb31c84b5ff097b58c13b180d Mon Sep 17 00:00:00 2001 From: Yunze Xu Date: Mon, 20 Jan 2025 22:08:08 +0800 Subject: [PATCH] [improve][broker] Remove spamming logs for customized managed ledger (#23862) (cherry picked from commit a93e93dddddc3751a2d29727fc5226b689fed204) (cherry picked from commit cae9f600ff17b8b2f563687f80971240de57246b) --- .../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 2fd0347c41f7b..0f6a6db2cd299 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 @@ -3243,8 +3243,8 @@ public CompletableFuture updateOldPositionInfo() { 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())) {