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;

Reply via email to