(pulsar) branch master updated: [fix][broker] Use `poll` instead `remove` to avoid `NoSuchElementException` (#24933)

[technoboy]

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

technoboy 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 402ed5bc0a5 [fix][broker] Use `poll` instead `remove` to avoid 
`NoSuchElementException` (#24933)
402ed5bc0a5 is described below

commit 402ed5bc0a50b07fc7baff6c9c6a0ed0eb07a6b5
Author: Jiwei Guo <techno...@apache.org>
AuthorDate: Mon Nov 3 18:53:59 2025 +0800

    [fix][broker] Use `poll` instead `remove` to avoid `NoSuchElementException` 
(#24933)
---
 .../src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java
index 02c0fd568d8..c3f8254fb5e 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java
@@ -218,7 +218,10 @@ public class RawReaderImpl implements RawReader {
         private void failPendingRawReceives() {
             List<CompletableFuture<RawMessage>> toError = new ArrayList<>();
             while (!pendingRawReceives.isEmpty()) {
-                toError.add(pendingRawReceives.remove());
+                final CompletableFuture<RawMessage> ret = 
pendingRawReceives.poll();
+                if (ret != null) {
+                    toError.add(ret);
+                }
             }
             toError.forEach((f) -> f.cancel(false));
         }