public String getTargetFieldType(String fieldName){
        int fieldIndex = sideTableInfo.getFieldList().indexOf(fieldName);
        if(fieldIndex == -1){
            throw new RuntimeException(sideTableInfo.getName() + " can't find field: " + fieldName);
        }

        return sideTableInfo.getFieldTypes()[fieldIndex];
    }
Reason:
Date: 2018/9/18
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java