seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/TableSchemaServiceImpl.java [93:109]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        pluginName = pluginName.toUpperCase();
        if (pluginName.endsWith("-CDC")) {
            pluginName = pluginName.replace("-CDC", "");
        } else if (pluginName.startsWith("JDBC_")) {
            pluginName = pluginName.replace("JDBC_", "");
        } else if (pluginName.startsWith("JDBC-")) {
            pluginName = pluginName.replace("JDBC-", "");
        }
        // if the convertor is not exist in the plugin, will use the input type as the output type
        DataTypeConvertor<?> convertor;
        try {
            convertor = factory.getDataTypeConvertor(pluginName);
        } catch (Exception e) {
            convertor = new EngineDataType.SeaTunnelDataTypeConvertor();
            log.warn(
                    "The convertor of plugin: {} is not exist, will use EngineDataType.SeaTunnelDataTypeConvertor",
                    pluginName);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/TableSchemaServiceImpl.java [124:140]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        pluginName = pluginName.toUpperCase();
        if (pluginName.endsWith("-CDC")) {
            pluginName = pluginName.replace("-CDC", "");
        } else if (pluginName.startsWith("JDBC_")) {
            pluginName = pluginName.replace("JDBC_", "");
        } else if (pluginName.startsWith("JDBC-")) {
            pluginName = pluginName.replace("JDBC-", "");
        }
        // if the convertor is not exist in the plugin, will use the input type as the output type
        DataTypeConvertor<?> convertor;
        try {
            convertor = factory.getDataTypeConvertor(pluginName);
        } catch (Exception e) {
            convertor = new EngineDataType.SeaTunnelDataTypeConvertor();
            log.warn(
                    "The convertor of plugin: {} is not exist, will use EngineDataType.SeaTunnelDataTypeConvertor",
                    pluginName);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -