public void testAllOperate() {
        groupInfo = createInlongGroup(GROUP_ID, MQType.PULSAR);
        groupService.updateStatus(GROUP_ID, GroupStatus.CONFIG_ING.getCode(), GLOBAL_OPERATOR);
        groupService.updateStatus(GROUP_ID, GroupStatus.CONFIG_SUCCESSFUL.getCode(), GLOBAL_OPERATOR);
        groupService.update(groupInfo.genRequest(), GLOBAL_OPERATOR);

        Integer sourceId = this.createBinlogSource(groupInfo);
        testFrozenSource(sourceId);
        testRestartSource(sourceId);
    }
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