This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit ccbb43398f59d64d501e8d709745885c00fb7070 Author: Jiwei Guo <[email protected]> AuthorDate: Mon Nov 3 18:53:59 2025 +0800 [fix][broker] Use `poll` instead `remove` to avoid `NoSuchElementException` (#24933) (cherry picked from commit 402ed5bc0a50b07fc7baff6c9c6a0ed0eb07a6b5) --- .../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 32f75d71dc3..da89cfeba98 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 @@ -208,7 +208,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)); }
