@Override
    public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, Object> props) {
        props.put(JdbcCheckKeys.DRIVER_NAME, "com.microsoft.sqlserver.jdbc.SQLServerDriver");
        AbstractTableInfo sqlserverTableInfo = super.getTableInfo(tableName, fieldsInfo, props);
        sqlserverTableInfo.setType(CURR_TYPE);
        return sqlserverTableInfo;
    }
Reason:
Date: 2018/11/27
Company: www.dtstack.com

@author maqi
sqlserver/sqlserver-sink/src/main/java/com/dtstack/flink/sql/sink/sqlserver/table/SqlserverSinkParser.java