You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/03/12 16:05:25 UTC
[incubator-inlong] branch master updated: [INLONG-3095][Manager] Update inlong group info in the complete listeners (#3096)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 0d88155 [INLONG-3095][Manager] Update inlong group info in the complete listeners (#3096)
0d88155 is described below
commit 0d881550e90ae97bdfa38a43710ac02e504a1a85
Author: healchow <he...@gmail.com>
AuthorDate: Sun Mar 13 00:05:18 2022 +0800
[INLONG-3095][Manager] Update inlong group info in the complete listeners (#3096)
---
.../workflow/group/listener/GroupCompleteProcessListener.java | 5 ++++-
.../service/workflow/group/listener/UpdateGroupCompleteListener.java | 2 ++
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/GroupCompleteProcessListener.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/GroupCompleteProcessListener.java
index 3d8f92b..31d9e0a 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/GroupCompleteProcessListener.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/GroupCompleteProcessListener.java
@@ -65,8 +65,11 @@ public class GroupCompleteProcessListener implements ProcessEventListener {
GroupResourceProcessForm form = (GroupResourceProcessForm) context.getProcessForm();
String groupId = form.getInlongGroupId();
String applicant = context.getApplicant();
- // Update status of inlong group, inlong stream...
+ // Update inlong group status and other info
groupService.updateStatus(groupId, GroupState.CONFIG_SUCCESSFUL.getCode(), applicant);
+ groupService.update(form.getGroupInfo().genRequest(), applicant);
+
+ // Update status of other related configs
streamService.updateStatus(groupId, null, EntityStatus.STREAM_CONFIG_SUCCESSFUL.getCode(), applicant);
// TODO Remove update source file / db detail status
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/UpdateGroupCompleteListener.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/UpdateGroupCompleteListener.java
index 9946bb2..2abaa93 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/UpdateGroupCompleteListener.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/UpdateGroupCompleteListener.java
@@ -65,7 +65,9 @@ public class UpdateGroupCompleteListener implements ProcessEventListener {
default:
throw new RuntimeException(String.format("Unsupported operation=%s for Inlong group", operateType));
}
+ // Update inlong group status and other info
groupService.updateStatus(groupInfo.getInlongGroupId(), nextStatus, username);
+ groupService.update(groupInfo.genRequest(), username);
return ListenerResult.success();
}