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;
                                 });

Reply via email to