@Override
    public String getSourceToSinkFieldTypeMapping(String sourceType) {
        if (reader == null) {
            return sourceType;
        }
        String dataType = StringUtils.substringBefore(sourceType, LEFT_BRACKET).toUpperCase();
        return reader.getSourceToSinkFieldTypeMap().getOrDefault(dataType, sourceType.toUpperCase());
    }
The default field type mapping strategy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/fieldtype/strategy/DefaultFieldTypeStrategy.java