(inlong) branch master updated: [INLONG-9863][Agent] Avoiding data loss caused by too many supplementary files (#9864)

[zirui]

This is an automated email from the ASF dual-hosted git repository.

zirui 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 c12be71518 [INLONG-9863][Agent] Avoiding data loss caused by too many 
supplementary files (#9864)
c12be71518 is described below

commit c12be71518d484e0e540996d51d9627f0c2c7510
Author: justinwwhuang <hww_jus...@163.com>
AuthorDate: Fri Mar 22 14:57:02 2024 +0800

    [INLONG-9863][Agent] Avoiding data loss caused by too many supplementary 
files (#9864)
---
 .../main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java
 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java
index d6fc5acd6c..b49a72313c 100644
--- 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java
+++ 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java
@@ -299,9 +299,9 @@ public class LogFileTask extends Task {
     private void runForRetry() {
         if (!runAtLeastOneTime) {
             scanExistingFile();
-            dealWithEventMap();
             runAtLeastOneTime = true;
         }
+        dealWithEventMap();
         if (instanceManager.allInstanceFinished()) {
             LOGGER.info("retry task finished, send action to task manager, 
taskId {}", getTaskId());
             TaskAction action = new 
TaskAction(org.apache.inlong.agent.core.task.ActionType.FINISH, taskProfile);