public HiveSinkRequest createHiveSink(InlongStreamInfo streamInfo) {
        HiveSinkRequest sinkRequest = new HiveSinkRequest();
        sinkRequest.setInlongGroupId(streamInfo.getInlongGroupId());
        sinkRequest.setSinkType("HIVE");
        sinkRequest.setSinkName("HIVE");
        sinkRequest.setInlongStreamId(streamInfo.getInlongStreamId());
        List<SinkField> sinkFields = createStreamFields(streamInfo.getInlongGroupId(),
                streamInfo.getInlongStreamId())
                        .stream()
                        .map(streamField -> {
                            SinkField fieldInfo = new SinkField();
                            fieldInfo.setFieldName(streamField.getFieldName());
                            fieldInfo.setFieldType(streamField.getFieldType());
                            fieldInfo.setFieldComment(streamField.getFieldComment());
                            return fieldInfo;
                        })
                        .collect(Collectors.toList());
        sinkRequest.setSinkFieldList(sinkFields);
        sinkRequest.setEnableCreateResource(0);
        sinkRequest.setUsername(OPERATOR);
        sinkRequest.setPassword("password");
        sinkRequest.setDbName("default");
        sinkRequest.setTableName("kip_test");
        sinkRequest.setJdbcUrl("jdbc:hive2://localhost:7001");
        sinkRequest.setFileFormat("TextFile");
        sinkRequest.setDataPath("hdfs://localhost:4007/user/hive/warehouse/default");
        sinkRequest.setFileFormat(StandardCharsets.UTF_8.name());
        sinkRequest.setDataSeparator("|");
        streamSinkService.save(sinkRequest, OPERATOR);
        return sinkRequest;
    }
Create Hive sink by inlong stream info.
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/DisableZkForSortTest.java