(pulsar) branch branch-3.1 updated: [improve][broker] Print recoverBucketSnapshot log if cursorProperties are empty (#21651)

[technoboy]

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

technoboy pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.1 by this push:
     new 2393ca7c3f9 [improve][broker] Print recoverBucketSnapshot log if 
cursorProperties are empty (#21651)
2393ca7c3f9 is described below

commit 2393ca7c3f977404101875e0e1b6e6880452fa2e
Author: Cong Zhao <zhaoc...@apache.org>
AuthorDate: Mon Dec 4 10:23:00 2023 +0800

    [improve][broker] Print recoverBucketSnapshot log if cursorProperties are 
empty (#21651)
---
 .../pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
index d7a3e80f086..f98c9e000f1 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
@@ -140,6 +140,8 @@ public class BucketDelayedDeliveryTracker extends 
AbstractDelayedDeliveryTracker
         ManagedCursor cursor = this.lastMutableBucket.getCursor();
         Map<String, String> cursorProperties = cursor.getCursorProperties();
         if (MapUtils.isEmpty(cursorProperties)) {
+            log.info("[{}] Recover delayed message index bucket snapshot 
finish, don't find bucket snapshot",
+                    dispatcher.getName());
             return 0;
         }
         FutureUtil.Sequencer<Void> sequencer = 
this.lastMutableBucket.getSequencer();