| commit | 2393ca7c3f977404101875e0e1b6e6880452fa2e | [log] [tgz] |
|---|---|---|
| author | Cong Zhao <zhaocong@apache.org> | Mon Dec 04 10:23:00 2023 +0800 |
| committer | Jiwe Guo <technoboy@apache.org> | Fri Dec 08 11:18:14 2023 +0800 |
| tree | b21f059c06b5897c8d906f80cd69a51e34e51410 | |
| parent | 89b56a1abf0fe703d348c8c864c6a14045fa0ec8 [diff] |
[improve][broker] Print recoverBucketSnapshot log if cursorProperties are empty (#21651)
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 d7a3e80..f98c9e0 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 @@ 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();