do not close pulsar client when a sort task exit

apache · Jan 27, 2025 · 035482c · 035482c
1 parent b155956
commit 035482c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...k/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java b/...k/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java
@@ -199,7 +199,7 @@ public boolean clean() {
             }
 
             closeFetcher();
-            closePulsarClient();
+//            closePulsarClient();
             closeTubeSessionFactory();
             LOGGER.info("close finished {}", sortTaskId);
             return true;

diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java
@@ -88,7 +88,7 @@ public boolean clean() {
             LOGGER.info("start to clean topic manager, sortTaskId={}", sortTaskId);
             stopAssign = true;
             closeAllFetchers();
-            closeAllPulsarClients();
+//            closeAllPulsarClients();
             closeAllTubeFactories();
             LOGGER.info("success to clean topic manager, sortTaskId={}", sortTaskId);
             return true;