@Override
    public ListenerResult listen(WorkflowContext context) throws WorkflowListenerException {
        StreamResourceProcessForm form = (StreamResourceProcessForm) context.getProcessForm();
        InlongStreamInfo streamInfo = form.getStreamInfo();
        final String groupId = streamInfo.getInlongGroupId();
        final String streamId = streamInfo.getInlongStreamId();
        final String operator = context.getOperator();
        InlongStreamInfo originStreamInfo = streamService.get(groupId, streamId);
        if (originStreamInfo == null) {
            throw new BusinessException(ErrorCodeEnum.STREAM_NOT_FOUND);
        }
        streamService.updateStatus(groupId, streamId, StreamStatus.CONFIG_ING.getCode(), operator);
        return ListenerResult.success();
    }
The listener for initial the InlongStream information.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/stream/InitStreamListener.java