[INLONG-10047][Agent] Fix the bug in the logic for judging the comple…

…tion status of the supplementary recording task (#10050)
apache · Apr 23, 2024 · 5916eef · 5916eef
1 parent 5383f19
commit 5916eef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java b/...ent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/file/LogFileTask.java
@@ -236,7 +236,7 @@ private void runForRetry() {
             runAtLeastOneTime = true;
         }
         dealWithEventMap();
-        if (allInstanceFinished()) {
+        if (instanceQueue.isEmpty() && 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);
             taskManager.submitAction(action);