[inlong] branch master updated: [INLONG-8244][Agent] Fix the thread leaks after job finished (#8245)

[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 c599d71faf [INLONG-8244][Agent] Fix the thread leaks after job 
finished (#8245)
c599d71faf is described below

commit c599d71faf03d40ac6617f4e721032a57a3a659f
Author: justinwwhuang <hww_jus...@163.com>
AuthorDate: Thu Jun 15 12:47:46 2023 +0800

    [INLONG-8244][Agent] Fix the thread leaks after job finished (#8245)
---
 .../inlong/agent/plugin/sources/reader/file/TriggerFileReader.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/TriggerFileReader.java
 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/TriggerFileReader.java
index b747ae3595..f87de408cc 100644
--- 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/TriggerFileReader.java
+++ 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/TriggerFileReader.java
@@ -31,6 +31,8 @@ public class TriggerFileReader implements Reader {
     @NotNull
     private String triggerId;
 
+    private volatile boolean finished = false;
+
     @Override
     public Message read() {
         try {
@@ -44,7 +46,7 @@ public class TriggerFileReader implements Reader {
 
     @Override
     public boolean isFinished() {
-        return false;
+        return finished;
     }
 
     @Override
@@ -69,7 +71,7 @@ public class TriggerFileReader implements Reader {
 
     @Override
     public void finishRead() {
-
+        finished = true;
     }
 
     @Override