protected void dealWaterMark(Matcher matcher, AbstractTableInfo tableInfo){
        AbstractSourceTableInfo sourceTableInfo = (AbstractSourceTableInfo) tableInfo;
        String eventTimeField = matcher.group(1);
        //FIXME Temporarily resolve the second parameter row_time_field
        Integer offset = MathUtil.getIntegerVal(matcher.group(3));
        sourceTableInfo.setEventTimeField(eventTimeField);
        sourceTableInfo.setMaxOutOrderness(offset);
    }
Reason:
Date: 2018/7/4
Company: www.dtstack.com

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