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 4494611b85 [INLONG-8781][Manager] Fix exception when batch task is
finished (#8782)
4494611b85 is described below
commit 4494611b851d77b9b548e151217a1d86f77c32ae
Author: kipshi <[email protected]>
AuthorDate: Wed Aug 23 16:03:57 2023 +0800
[INLONG-8781][Manager] Fix exception when batch task is finished (#8782)
Co-authored-by: kipshi <[email protected]>
---
.../main/java/org/apache/inlong/manager/common/enums/GroupStatus.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
index 5b65f10335..7b22b1bd23 100644
---
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
+++
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
@@ -65,11 +65,11 @@ public enum GroupStatus {
GROUP_STATE_AUTOMATON.put(APPROVE_REJECTED,
Sets.newHashSet(APPROVE_REJECTED, TO_BE_APPROVAL, DELETING));
GROUP_STATE_AUTOMATON.put(APPROVE_PASSED,
Sets.newHashSet(APPROVE_PASSED, CONFIG_ING, DELETING));
- GROUP_STATE_AUTOMATON.put(CONFIG_ING, Sets.newHashSet(CONFIG_ING,
CONFIG_FAILED, CONFIG_SUCCESSFUL));
+ GROUP_STATE_AUTOMATON.put(CONFIG_ING, Sets.newHashSet(CONFIG_ING,
CONFIG_FAILED, CONFIG_SUCCESSFUL, FINISH));
GROUP_STATE_AUTOMATON.put(CONFIG_FAILED,
Sets.newHashSet(CONFIG_FAILED, CONFIG_ING, CONFIG_SUCCESSFUL,
TO_BE_APPROVAL, DELETING));
GROUP_STATE_AUTOMATON.put(CONFIG_SUCCESSFUL,
- Sets.newHashSet(CONFIG_SUCCESSFUL, TO_BE_APPROVAL, CONFIG_ING,
SUSPENDING, DELETING, FINISH));
+ Sets.newHashSet(CONFIG_SUCCESSFUL, TO_BE_APPROVAL, CONFIG_ING,
SUSPENDING, DELETING));
GROUP_STATE_AUTOMATON.put(SUSPENDING, Sets.newHashSet(SUSPENDING,
SUSPENDED, CONFIG_FAILED));
GROUP_STATE_AUTOMATON.put(SUSPENDED, Sets.newHashSet(SUSPENDED,
RESTARTING, DELETING));