From 552c791c8c9fdfd5896b31d20e2e84b279c5381e Mon Sep 17 00:00:00 2001 From: Lari Hotari Date: Sat, 6 Nov 2021 13:44:56 +0200 Subject: [PATCH] [Java Client] Remove invalid call to Thread.currentThread().interrupt(); - 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 --- .../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 e89f390670335..5e0579fc73aa2 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 @@ -1799,7 +1799,6 @@ private void batchMessageAndSend() { processOpSendMsg(opSendMsg); } } catch (PulsarClientException e) { - Thread.currentThread().interrupt(); semaphoreRelease(batchMessageContainer.getNumMessagesInBatch()); } catch (Throwable t) { semaphoreRelease(batchMessageContainer.getNumMessagesInBatch());