@Override
    public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, Object> props) {
        props.put(JdbcCheckKeys.DRIVER_NAME, "org.postgresql.Driver");
        AbstractTableInfo pgTableInfo = super.getTableInfo(tableName, fieldsInfo, props);
        pgTableInfo.setType(CURR_TYPE);
        return pgTableInfo;
    }
Reason:
Date: 2019-08-11
Company: mmg

@author tcm
postgresql/postgresql-side/postgresql-side-core/src/main/java/com/dtstack/flink/sql/side/postgresql/table/PostgresqlSideParser.java