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(),