private Tuple2<String, String> extractType(String fieldRow, String tableName) {
        Matcher matcher = typePattern.matcher(fieldRow);
        if (matcher.matches()) {
            String fieldName = matcher.group(1);
            String fieldType = matcher.group(2);
            return Tuple2.of(fieldName, fieldType);
        } else {
            String errorMsg = String.format("table [%s] field [%s] format error.", tableName, fieldRow);
            throw new RuntimeException(errorMsg);
        }
    }
Reason:
Date: 2018/7/4
Company: www.dtstack.com

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