You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ni...@apache.org on 2022/09/13 07:41:40 UTC
[pulsar] branch branch-2.11 updated: [fix][client]Fix scheduledExecutorProvider not shutdown (#17527)
This is an automated email from the ASF dual-hosted git repository.
nicoloboschi pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new 913b74b8294 [fix][client]Fix scheduledExecutorProvider not shutdown (#17527)
913b74b8294 is described below
commit 913b74b82941d941fc846040dce77fc7f35bf88d
Author: Xiaoyu Hou <ho...@apache.org>
AuthorDate: Tue Sep 13 15:40:25 2022 +0800
[fix][client]Fix scheduledExecutorProvider not shutdown (#17527)
* Fix scheduledExecutorProvider not shutdown
* Fix check null
(cherry picked from commit a23963dacddeaefd0846c187755c43a19779f5d1)
---
.../src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
index c436f129789..8ba26e0d15e 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
@@ -894,7 +894,7 @@ public class PulsarClientImpl implements PulsarClient {
}
if (createdScheduledProviders && scheduledExecutorProvider != null && !scheduledExecutorProvider.isShutdown()) {
try {
- externalExecutorProvider.shutdownNow();
+ scheduledExecutorProvider.shutdownNow();
} catch (Throwable t) {
log.warn("Failed to shutdown scheduledExecutorProvider", t);
pulsarClientException = PulsarClientException.unwrap(t);