@BeforeEach
    private void prepareAll() {
        this.prepareCluster(TEST_CLUSTER_1, null);
        this.prepareCluster(TEST_CLUSTER_2, TEST_TAG);
        this.prepareCluster(TEST_CLUSTER_3, BACK_UP_TAG);
        this.preparePulsar("testPulsar", true, TEST_TAG);
        this.preparePulsar("backupPulsar", true, BACK_UP_TAG);
        this.prepareDataNode(TEST_TASK_1);
        this.prepareDataNode(TEST_TASK_2);
        this.prepareDataNode(TEST_TASK_3);
        this.prepareGroupId(TEST_GROUP);
        this.prepareStreamId(TEST_GROUP, TEST_STREAM_1, TEST_TOPIC_1);
        this.prepareStreamId(TEST_GROUP, TEST_STREAM_2, TEST_TOPIC_2);
        this.prepareTask(TEST_TASK_1, TEST_GROUP, TEST_CLUSTER_1, TEST_STREAM_1);
        this.prepareTask(TEST_TASK_1, TEST_GROUP, TEST_CLUSTER_1, TEST_STREAM_2);
        this.prepareTask(TEST_TASK_2, TEST_GROUP, TEST_CLUSTER_2, TEST_STREAM_1);
        this.prepareTask(TEST_TASK_3, TEST_GROUP, TEST_CLUSTER_3, TEST_STREAM_2);
    }
Sort service test for {@link SortService}
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java