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
