[pulsar] branch master updated: remove duplicated release (#16118)

[al...@apache.org]

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

aloyszhang 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 603a5cdd8e4 remove duplicated release (#16118)
603a5cdd8e4 is described below

commit 603a5cdd8e4f82a27c1341c93eb6162862d1e970
Author: Aloys <lo...@gmail.com>
AuthorDate: Tue Jun 21 09:26:13 2022 +0800

    remove duplicated release (#16118)
---
 .../src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java        | 1 -
 1 file changed, 1 deletion(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
index cb676b1062d..45a2cf96b48 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
@@ -1881,7 +1881,6 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
 
     public int clearIncomingMessagesAndGetMessageNumber() {
         int messagesNumber = incomingMessages.size();
-        incomingMessages.forEach(Message::release);
         clearIncomingMessages();
         unAckedMessageTracker.clear();
         return messagesNumber;