[inlong] branch master updated: [INLONG-7752][Agent] PulsarSink threadPool throw reject exception (#7753)

[do...@apache.org]

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 60f13268d [INLONG-7752][Agent] PulsarSink threadPool throw reject exception (#7753)
60f13268d is described below

commit 60f13268d4b8cb9d6b7fd8635ed5bdbbcf91f8a7
Author: wangpeix <10...@users.noreply.github.com>
AuthorDate: Mon Apr 3 15:25:25 2023 +0800

    [INLONG-7752][Agent] PulsarSink threadPool throw reject exception (#7753)
    
    Co-authored-by: wangpeix <lu...@didiglobal.com>
---
 .../src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java
index 031ee73e0..a5f066a9d 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java
@@ -196,7 +196,6 @@ public class PulsarSink extends AbstractSink {
             AgentUtils.silenceSleepInMs(batchFlushInterval);
         }
         shutdown = true;
-        EXECUTOR_SERVICE.shutdown();
         if (CollectionUtils.isNotEmpty(pulsarSenders)) {
             for (PulsarTopicSender sender : pulsarSenders) {
                 sender.close();