Yes.
________________________________ 发件人: Timo Walther <twal...@apache.org> 发送时间: 2018年4月25日 8:43 收件人: user@flink.apache.org 主题: Re: Why assignTimestampsAndWatermarks parallelism same as map，it will not fired？ Hi, did you set your time characteristics to even-time? env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); Regards, Timo Am 25.04.18 um 05:15 schrieb 潘 功森: > Hi all, > > > I use the same parallelism between map and assignTimestampsAndWatermarks , > and it not fired, I saw the extractTimestamp and generateWatermark all is > fine, but watermark is always not change and keep as min long value. > > And then I changed parallelism and different with map, and windows fired. > > I used Flink 1.3.2. > > Is it a Flink bug?or others can give me why it not fired. It troubled me the > whole day. > > > Best regards, > > September
