[INLONG-9138][Agent] Add task manager

justinwwhuang · Oct 27, 2023 · de38b11 · de38b11
1 parent b0ebf82
commit de38b11
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ng-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/file/TaskManager.java b/...ng-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/file/TaskManager.java
@@ -168,7 +168,7 @@ private void dealWithActionQueue(BlockingQueue<TaskAction> queue) {
                 TaskProfile profile = action.getProfile();
                 switch (action.getActionType()) {
                     case FINISH:
-                        LOGGER.info("test123 deal finish action, taskId {}", profile.getTaskId());
+                        LOGGER.info("deal finish action, taskId {}", profile.getTaskId());
                         finishTask(profile);
                         break;
                     default: