public static StarRocksSinkDTO getFromRequest(StarRocksSinkRequest request, String extParams) throws Exception {
        Integer encryptVersion = AESUtils.getCurrentVersion(null);

        StarRocksSinkDTO dto = StringUtils.isNotBlank(extParams)
                ? StarRocksSinkDTO.getFromJson(extParams)
                : new StarRocksSinkDTO();
        CommonBeanUtils.copyProperties(request, dto, true);
        String passwd = dto.getPassword();
        if (StringUtils.isNotEmpty(passwd)) {
            passwd = AESUtils.encryptToString(passwd.getBytes(StandardCharsets.UTF_8), encryptVersion);
        }

        dto.setEncryptVersion(encryptVersion);
        dto.setPassword(passwd);
        return dto;
    }
Get the dto instance from the request
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/starrocks/StarRocksSinkDTO.java