protected long getExtractTimestamp(Long extractTime){

        lastTime = extractTime + timezone.getOffset(extractTime);

        eventDelayGauge.setDelayTime(MathUtil.getIntegerVal((System.currentTimeMillis() - extractTime)/1000));

        return lastTime;
    }
Reason:
Date: 2018/10/18
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/watermarker/AbstractCustomerWaterMarker.java