[INLONG-8649][Agent]fix bug: proxysink thread leaks when the dataprox…

…y sdk init failed
justinwwhuang · Aug 7, 2023 · e16f35c · e16f35c
1 parent 716cafa
commit e16f35c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/ProxySink.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/ProxySink.java
@@ -183,10 +183,10 @@ public void init(JobProfile jobConf) {
         messageFilter = initMessageFilter(jobConf);
         fieldSplitter = jobConf.get(CommonConstants.FIELD_SPLITTER, DEFAULT_FIELD_SPLITTER).getBytes(
                 StandardCharsets.UTF_8);
-        executorService.execute(flushCache());
         senderManager = new SenderManager(jobConf, inlongGroupId, sourceName);
         try {
             senderManager.Start();
+            executorService.execute(flushCache());
         } catch (Throwable ex) {
             LOGGER.error("error while init sender for group id {}", inlongGroupId);
             ThreadUtils.threadThrowableHandler(Thread.currentThread(), ex);