@Override
    public ListenerResult listen(WorkflowContext context) throws Exception {
        ProcessForm processForm = context.getProcessForm();
        StreamResourceProcessForm streamResourceProcessForm = (StreamResourceProcessForm) processForm;
        InlongStreamInfo streamInfo = streamResourceProcessForm.getStreamInfo();
        log.info("inlong stream :{} ext info: {}", streamInfo.getInlongStreamId(), streamInfo.getExtList());

        String jobName = FlinkUtils.genFlinkJobName(processForm, streamInfo);
        return FlinkUtils.submitFlinkJob(streamInfo, jobName);
    }
Currently, the process of starting Sort tasks has been initiated in {@link StartupSortListener}.
<p/>Because the Sort task is only associated with InlongGroup, no need to start it for InlongStream.
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java