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;
/**