This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit f849d467689ed6e3e30438722e3ebc6779d059ae Author: Lari Hotari <[email protected]> AuthorDate: Sun Nov 7 01:50:13 2021 +0200 [Java Client] Remove invalid call to Thread.currentThread().interrupt(); (#12652) - Thread.currentThread().interrupt() shouldn't be called here. - it must only be called when handling an InterruptedException. - this looks like a copy-paste bug introduced in https://github.com/apache/pulsar/pull/731/files#diff-d6fcf8aa2d0035cc386dca0942a452343d6854763c7fd397efa4e660c0069767R1183 (cherry picked from commit b5f78f8ae5b4f2419e97044541722062fe388d9d) --- .../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java | 1 - 1 file changed, 1 deletion(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java index 0f27a63..34e4b6c 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java @@ -1775,7 +1775,6 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne processOpSendMsg(opSendMsg); } } catch (PulsarClientException e) { - Thread.currentThread().interrupt(); semaphore.ifPresent(s -> s.release(batchMessageContainer.getNumMessagesInBatch())); } catch (Throwable t) { semaphore.ifPresent(s -> s.release(batchMessageContainer.getNumMessagesInBatch()));
