You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2025/11/18 10:44:05 UTC
(inlong) branch master updated: [INLONG-11950][Agent] Missing case in switch statement (#12050)
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 <lu...@apache.org>
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(),