(inlong) branch master updated: [INLONG-9554][SDK] Fix the shutdownInternalThreads methods throw the NullPointerException (#9555)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new ddd0a3f01f [INLONG-9554][SDK] Fix the shutdownInternalThreads methods 
throw the NullPointerException (#9555)
ddd0a3f01f is described below

commit ddd0a3f01fcf67b4eca06d8acb255381b6eb486a
Author: castor <58140421+castor...@users.noreply.github.com>
AuthorDate: Tue Jan 9 16:02:21 2024 +0800

    [INLONG-9554][SDK] Fix the shutdownInternalThreads methods throw the 
NullPointerException (#9555)
    
    Co-authored-by: castorqin <qhj00...@qq.com>
---
 .../java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java | 7 -------
 1 file changed, 7 deletions(-)

diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
index c9fedd3450..7b655b29fa 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
@@ -77,12 +77,6 @@ public class DefaultMessageSender implements MessageSender {
         indexCol = new IndexCollectThread(storeIndex);
         indexCol.start();
 
-        if (configure.isEnableSaveManagerVIps()
-                && configure.isRequestByHttp()
-                && MANAGER_FETCHER_THREAD_STARTED.compareAndSet(false, true)) {
-            managerFetcherThread = new ManagerFetcherThread(configure);
-            managerFetcherThread.start();
-        }
     }
 
     /**
@@ -847,7 +841,6 @@ public class DefaultMessageSender implements MessageSender {
 
     private void shutdownInternalThreads() {
         indexCol.shutDown();
-        managerFetcherThread.shutdown();
         MANAGER_FETCHER_THREAD_STARTED.set(false);
     }