[pulsar] branch branch-2.10 updated: [fix][client]Fix scheduledExecutorProvider not shutdown (#17527)

[nicoloboschi]

This is an automated email from the ASF dual-hosted git repository.

nicoloboschi pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 296f0f027e8 [fix][client]Fix scheduledExecutorProvider not shutdown 
(#17527)
296f0f027e8 is described below

commit 296f0f027e89667c55961685a633d49b80bcb874
Author: Xiaoyu Hou <houxia...@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 0f6f447bdf3..4d44ea90350 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
@@ -869,7 +869,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);