[inlong] branch master updated: [INLONG-8649][Agent] Fix the proxysink thread leaks when the dataproxy sdk init failed (#8650)

[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 1ad696b1ed [INLONG-8649][Agent] Fix the proxysink thread leaks when 
the dataproxy sdk init failed (#8650)
1ad696b1ed is described below

commit 1ad696b1ed52c42d5f4ee6cb096a538ecff224e1
Author: justinwwhuang <hww_jus...@163.com>
AuthorDate: Mon Aug 7 17:11:43 2023 +0800

    [INLONG-8649][Agent] Fix the proxysink thread leaks when the dataproxy sdk 
init failed (#8650)
---
 .../src/main/java/org/apache/inlong/agent/plugin/sinks/ProxySink.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index 7bf723e965..c3a5bbfc07 100755
--- 
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 class ProxySink extends AbstractSink {
         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);