flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired?
Date Wed, 25 Apr 2018 08:43:12 GMT
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



Mime
View raw message