Fix scheduledExecutorProvider not shutdown

apache · Sep 8, 2022 · 5d41763 · 5d41763
1 parent cbe94af
commit 5d41763
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -892,9 +892,9 @@ private void shutdownExecutors() throws PulsarClientException {
                 }
             }
         }
-        if (createdScheduledProviders && scheduledExecutorProvider != null && !scheduledExecutorProvider.isShutdown()) {
+        if (createdScheduledProviders && !scheduledExecutorProvider.isShutdown()) {
             try {
-                externalExecutorProvider.shutdownNow();
+                scheduledExecutorProvider.shutdownNow();
             } catch (Throwable t) {
                 log.warn("Failed to shutdown scheduledExecutorProvider", t);
                 pulsarClientException = PulsarClientException.unwrap(t);