flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 潘 功森 <pangong...@hotmail.com>
Subject Why assignTimestampsAndWatermarks parallelism same as map,it will not fired?
Date Wed, 25 Apr 2018 03:15:50 GMT
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,

View raw message