From e0db2f1980e577a455323e16865b17b2aba0e690 Mon Sep 17 00:00:00 2001 From: fengyubiao Date: Mon, 22 Jul 2024 09:27:23 +0800 Subject: [PATCH] fix bug --- .../java/org/apache/pulsar/broker/service/BrokerService.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java index e8e94cbee56c6..c0da47755b630 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java @@ -1657,6 +1657,7 @@ public void openLedgerFailed(ManagedLedgerException exception, Object ctx) { if (!createIfMissing && exception instanceof ManagedLedgerNotFoundException) { // We were just trying to load a topic and the topic doesn't exist topicFuture.complete(Optional.empty()); + pulsar.getExecutor().execute(() -> topics.remove(topic, topicFuture)); } else { log.warn("Failed to create topic {}", topic, exception); pulsar.getExecutor().execute(() -> topics.remove(topic, topicFuture));