private void prepareTask(String taskName, String groupId, String clusterName, String streamId) {
        SinkRequest request = new HiveSinkRequest();
        request.setDataNodeName(taskName);
        request.setSinkType(SinkType.HIVE);
        request.setInlongClusterName(clusterName);
        request.setSinkName(taskName);
        request.setSortTaskName(taskName);
        request.setInlongGroupId(groupId);
        request.setInlongStreamId(streamId);
        Map<String, Object> properties = new HashMap<>();
        properties.put("delimiter", "|");
        properties.put("dataType", "text");
        request.setProperties(properties);
        streamSinkService.save(request, GLOBAL_OPERATOR);
    }
Sort service test for {@link SortService}
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java