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 c436f12978976..8ba26e0d15e29 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 @@ private void shutdownExecutors() throws PulsarClientException { } 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);