Why assignTimestampsAndWatermarks parallelism same as map，it will not fired？

Posted by 潘 功森 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Why-assignTimestampsAndWatermarks-parallelism-same-as-map-it-will-not-fired-tp19733.html

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