private void handleKeyNotHaveAlias(String fieldRow, AbstractTableInfo tableInfo) {
        Tuple2<String, String> t = extractType(fieldRow, tableInfo.getName());
        String fieldName = t.f0;
        String fieldType = t.f1;

        Class fieldClass;
        AbstractTableInfo.FieldExtraInfo fieldExtraInfo = null;

        Matcher matcher = charTypePattern.matcher(fieldType);
        if (matcher.find()) {
            fieldClass = dbTypeConvertToJavaType(CHAR_TYPE_NO_LENGTH);
            fieldExtraInfo = new AbstractTableInfo.FieldExtraInfo();
            fieldExtraInfo.setLength(Integer.parseInt(matcher.group(1)));
        } else {
            fieldClass = dbTypeConvertToJavaType(fieldType);
        }

        tableInfo.addPhysicalMappings(fieldName, fieldName);
        tableInfo.addField(fieldName);
        tableInfo.addFieldClass(fieldClass);
        tableInfo.addFieldType(fieldType);
        tableInfo.addFieldExtraInfo(fieldExtraInfo);
    }
Reason:
Date: 2018/7/4
Company: www.dtstack.com

@author xuchao
core/src/main/java/com/dtstack/flink/sql/table/AbstractTableParser.java