This is an automated email from the ASF dual-hosted git repository.
xiangying pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.10 by this push:
new d22daef20ed [branch-2.10][fix] Fix the compile issue of Branch-2.10
(#19181)
d22daef20ed is described below
commit d22daef20ed5ffe3a23f01bcc6ea610d0a19dbd4
Author: Xiangying Meng <[email protected]>
AuthorDate: Wed Jan 11 18:51:11 2023 +0800
[branch-2.10][fix] Fix the compile issue of Branch-2.10 (#19181)
---
.../pulsar/broker/service/persistent/MessageRedeliveryController.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryController.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryController.java
index e6febc722de..a8f6c14c537 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryController.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryController.java
@@ -46,8 +46,7 @@ public class MessageRedeliveryController {
if (!allowOutOfOrderDelivery) {
this.hashesToBeBlocked = ConcurrentLongLongPairHashMap
.newBuilder().concurrencyLevel(2).expectedItems(128).autoShrink(true).build();
- this.hashesRefCount = ConcurrentLongLongHashMap
-
.newBuilder().concurrencyLevel(2).expectedItems(128).autoShrink(true).build();
+ this.hashesRefCount = new ConcurrentLongLongHashMap(128, 2);
} else {
this.hashesToBeBlocked = null;
this.hashesRefCount = null;