[pulsar] branch master updated: [improve] [broker] Print warn log if compaction failure (#19405)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy 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 5b322209f9a [improve] [broker] Print warn log if compaction failure 
(#19405)
5b322209f9a is described below

commit 5b322209f9a0cc34874339db20778a1f272a9309
Author: fengyubiao <yubiao.f...@streamnative.io>
AuthorDate: Sat Feb 4 14:15:50 2023 +0800

    [improve] [broker] Print warn log if compaction failure (#19405)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 5 +++++
 1 file changed, 5 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 f6d02c73211..2b951cd9e3b 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
@@ -3031,6 +3031,11 @@ public class PersistentTopic extends AbstractTopic 
implements Topic, AddEntryCal
             } else {
                 currentCompaction = 
brokerService.pulsar().getCompactor().compact(topic);
             }
+            currentCompaction.whenComplete((ignore, ex) -> {
+               if (ex != null){
+                   log.warn("[{}] Compaction failure.", topic, ex);
+               }
+            });
         } else {
             throw new AlreadyRunningException("Compaction already in 
progress");
         }