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 b19119e4d6 [INLONG-11950][Agent] Missing case in switch statement 
(#12050)
b19119e4d6 is described below

commit b19119e4d6183bd30a8d3cc9ddde4d99a090ace7
Author: ChunLiang Lu <[email protected]>
AuthorDate: Tue Nov 18 18:44:00 2025 +0800

    [INLONG-11950][Agent] Missing case in switch statement (#12050)
---
 .../apache/inlong/agent/core/instance/InstanceManager.java | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java
 
b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java
index 9770939ea9..ec12362b71 100644
--- 
a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java
+++ 
b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java
@@ -231,14 +231,14 @@ public class InstanceManager extends AbstractDaemon {
                     break;
                 }
                 case FINISHED:
-                    DELETE: {
-                        if (instance != null) {
-                            LOGGER.info("traverseStoreTasksToMemory delete 
instance from mem taskId {} instanceId {}",
-                                    profileFromStore.getTaskId(), 
profileFromStore.getInstanceId());
-                            deleteFromMemory(profileFromStore.getInstanceId());
-                        }
-                        break;
+                case DELETE: {
+                    if (instance != null) {
+                        LOGGER.info("traverseStoreTasksToMemory delete 
instance from mem taskId {} instanceId {}",
+                                profileFromStore.getTaskId(), 
profileFromStore.getInstanceId());
+                        deleteFromMemory(profileFromStore.getInstanceId());
                     }
+                    break;
+                }
                 default: {
                     LOGGER.error("instance invalid state {} taskId {} 
instanceId {}", storeState,
                             profileFromStore.getTaskId(),

Reply via email to