private Integer createBinlogSource(InlongGroupInfo groupInfo) {
        InlongStreamInfo stream = createStreamInfo(groupInfo, STREAM_ID);
        MySQLBinlogSourceRequest sourceRequest = new MySQLBinlogSourceRequest();
        sourceRequest.setInlongGroupId(stream.getInlongGroupId());
        sourceRequest.setInlongStreamId(stream.getInlongStreamId());
        sourceRequest.setSourceName("binlog-collect");
        return sourceService.save(sourceRequest, GLOBAL_OPERATOR);
    }
There will be concurrency problems in the overall operation,This method temporarily fails the test
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/source/listener/StreamSourceListenerTest.java