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 7cade2f8435..db8cffbbe16 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.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.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 ListenerResult listen(WorkflowContext context) throws WorkflowListenerExc InlongGroupRequest updateGroupRequest = groupInfo.genRequest(); updateGroupRequest.setVersion(existGroup.getVersion()); groupService.update(updateGroupRequest, operator); + List 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