[fix][client]Fix scheduledExecutorProvider not shutdown (apache#17527)

* Fix scheduledExecutorProvider not shutdown * Fix check null (cherry picked from commit a23963d)
datastax · Sep 13, 2022 · 296f0f0 · 296f0f0
1 parent 8bd3b7a
commit 296f0f0
Showing 1 changed file with 1 addition and 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
@@ -869,7 +869,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);