You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ma...@apache.org on 2022/05/25 09:08:02 UTC

[pulsar] branch branch-2.9 updated: Fix cherry-picking issue with #15137

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

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


The following commit(s) were added to refs/heads/branch-2.9 by this push:
     new d3796e24c7a Fix cherry-picking issue with #15137
d3796e24c7a is described below

commit d3796e24c7a9d4a0174e0e987ffa4cbba4c50ccc
Author: mattison chao <ma...@gmail.com>
AuthorDate: Wed May 25 17:06:21 2022 +0800

    Fix cherry-picking issue with #15137
---
 .../pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java
index 5fc210ca741..e6d16fb7eae 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java
@@ -76,7 +76,7 @@ public class MLPendingAckStore implements PendingAckStore {
     private final AtomicLong currentIndexLag = new AtomicLong(0);
     private volatile long maxIndexLag;
 
-    protected PositionImpl maxAckPosition = PositionImpl.EARLIEST;
+    protected PositionImpl maxAckPosition = PositionImpl.earliest;
     private final LogIndexLagBackoff logIndexBackoff;
 
     /**