private OceanBaseSinkDTO getOceanBaseInfo(SinkInfo sinkInfo) {
        OceanBaseSinkDTO OceanBaseInfo = OceanBaseSinkDTO.getFromJson(sinkInfo.getExtParams());

        if (StringUtils.isBlank(OceanBaseInfo.getJdbcUrl())) {
            String dataNodeName = sinkInfo.getDataNodeName();
            Preconditions.expectNotBlank(dataNodeName, ErrorCodeEnum.INVALID_PARAMETER,
                    "OceanBase jdbc url not specified and data node is empty");
            DataNodeInfo dataNodeInfo = dataNodeHelper.getDataNodeInfo(dataNodeName, sinkInfo.getSinkType());
            CommonBeanUtils.copyProperties(dataNodeInfo, OceanBaseInfo);
            OceanBaseInfo.setJdbcUrl(OceanBaseDataNodeDTO.convertToJdbcurl(dataNodeInfo.getUrl()));
            OceanBaseInfo.setPassword(dataNodeInfo.getToken());
        }
        return OceanBaseInfo;
    }
Create OceanBase table by SinkInfo.

@param sinkInfo {@link SinkInfo}
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseResourceOperator.java