This is an automated email from the ASF dual-hosted git repository.
daojun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b4f710d96b6 [improve][broker] Add logs to `getInternalStats` for
quickly locate problem when schema ledger is lost (#22233)
b4f710d96b6 is described below
commit b4f710d96b68abbbb0f97d2bb4f38a22fde13e35
Author: hanmz <[email protected]>
AuthorDate: Mon Mar 11 18:59:31 2024 +0800
[improve][broker] Add logs to `getInternalStats` for quickly locate problem
when schema ledger is lost (#22233)
---
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 2 ++
1 file changed, 2 insertions(+)
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 c4f7be6b018..9111aafb2af 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
@@ -2665,6 +2665,8 @@ public class PersistentTopic extends AbstractTopic
implements Topic, AddEntryCal
stats.schemaLedgers.add(schemaLedgerInfo);
completableFuture.complete(null);
}).exceptionally(e -> {
+ log.error("[{}] Failed to get ledger
metadata for the schema ledger {}",
+ topic, ledgerId, e);
completableFuture.completeExceptionally(e);
return null;
});