[INLONG-9554][SDK] Fix the shutdownInternalThreads methods throw the …

…NullPointerException (#9555) Co-authored-by: castorqin <qhj00725@qq.com>
apache · Jan 9, 2024 · ddd0a3f · ddd0a3f
1 parent e91719b
commit ddd0a3f
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/...sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java b/...sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
@@ -77,12 +77,6 @@ public DefaultMessageSender(ProxyClientConfig configure, ThreadFactory selfDefin
         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 String sendMessageFile(byte[] body, String groupId, String streamId, long
 
     private void shutdownInternalThreads() {
         indexCol.shutDown();
-        managerFetcherThread.shutdown();
         MANAGER_FETCHER_THREAD_STARTED.set(false);
     }