(inlong) branch master updated: [INLONG-9447][Manager] Fix the problem of suspend group failed (#9448)

[dockerzhang]

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 9d6a5f638d [INLONG-9447][Manager] Fix the problem of suspend group 
failed (#9448)
9d6a5f638d is described below

commit 9d6a5f638d01c72a75b10fb605932dc2525e34fb
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Dec 8 19:15:41 2023 +0800

    [INLONG-9447][Manager] Fix the problem of suspend group failed (#9448)
---
 .../manager/service/listener/group/InitGroupCompleteListener.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/group/InitGroupCompleteListener.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/group/InitGroupCompleteListener.java
index 7cade2f843..db8cffbbe1 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/group/InitGroupCompleteListener.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/group/InitGroupCompleteListener.java
@@ -28,6 +28,7 @@ import 
org.apache.inlong.manager.dao.mapper.InlongGroupEntityMapper;
 import org.apache.inlong.manager.pojo.group.InlongGroupInfo;
 import org.apache.inlong.manager.pojo.group.InlongGroupRequest;
 import org.apache.inlong.manager.pojo.group.InlongGroupUtils;
+import org.apache.inlong.manager.pojo.stream.InlongStreamInfo;
 import 
org.apache.inlong.manager.pojo.workflow.form.process.GroupResourceProcessForm;
 import org.apache.inlong.manager.service.group.InlongGroupService;
 import org.apache.inlong.manager.service.source.StreamSourceService;
@@ -37,9 +38,12 @@ import 
org.apache.inlong.manager.workflow.event.ListenerResult;
 import org.apache.inlong.manager.workflow.event.process.ProcessEventListener;
 
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 /**
  * The listener of InlongGroup when created resources successfully.
  */
@@ -86,6 +90,10 @@ public class InitGroupCompleteListener implements 
ProcessEventListener {
             InlongGroupRequest updateGroupRequest = groupInfo.genRequest();
             updateGroupRequest.setVersion(existGroup.getVersion());
             groupService.update(updateGroupRequest, operator);
+            List<InlongStreamInfo> streamInfos = form.getStreamInfos();
+            if (CollectionUtils.isNotEmpty(streamInfos)) {
+                streamInfos.forEach(streamInfo -> 
streamService.updateWithoutCheck(streamInfo.genRequest(), operator));
+            }
             streamService.updateStatus(groupId, null, 
StreamStatus.CONFIG_SUCCESSFUL.getCode(), operator);
 
             // update status of other related configs