[pulsar] branch master updated: [improve][broker]Fix recycling OpReadEntry without resetting count (#19285)

[pe...@apache.org]

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

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new ad8d2dfc261 [improve][broker]Fix recycling OpReadEntry without resetting count (#19285)
ad8d2dfc261 is described below

commit ad8d2dfc261b54551d657092165a5b6803b6f4d4
Author: gaozhangmin <zh...@apache.org>
AuthorDate: Sat Jan 28 20:23:11 2023 +0800

    [improve][broker]Fix recycling OpReadEntry without resetting count (#19285)
---
 .../src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
index 04437b5320d..81b14359514 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
@@ -197,6 +197,7 @@ class OpReadEntry implements ReadEntriesCallback {
     };
 
     public void recycle() {
+        count = 0;
         cursor = null;
         readPosition = null;
         callback = null;