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

[潘 功森]

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