private HiveSinkDTO getHiveInfo(SinkInfo sinkInfo) {
        HiveSinkDTO hiveInfo = HiveSinkDTO.getFromJson(sinkInfo.getExtParams());

        // read from data node if not supplied by user
        if (StringUtils.isBlank(hiveInfo.getJdbcUrl())) {
            String dataNodeName = sinkInfo.getDataNodeName();
            Preconditions.expectNotBlank(dataNodeName, ErrorCodeEnum.INVALID_PARAMETER,
                    "hive jdbc url not specified and data node is empty");
            HiveDataNodeInfo dataNodeInfo = (HiveDataNodeInfo) dataNodeHelper.getDataNodeInfo(
                    dataNodeName, sinkInfo.getSinkType());
            CommonBeanUtils.copyProperties(dataNodeInfo, hiveInfo);
            hiveInfo.setJdbcUrl(dataNodeInfo.getUrl());
            hiveInfo.setPassword(dataNodeInfo.getToken());
        }
        return hiveInfo;
    }
Create hive table according to the groupId and hive config
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hive/HiveResourceOperator.java