The event is running all the time in order，I don't know why one of the partitions does not receive data if not change parallelism?
发件人: Fabian Hueske <fhueske@xxxxxxxxx>
发送时间: 2018年4月25日 10:56
收件人: Timo Walther
主题: Re: Why assignTimestampsAndWatermarks parallelism same as map，it will not fired？
This sounds like one of the partitions does not receive data. Watermark generation is data driven, i.e., the watermark can only advance if the TimestampAndWatermarkAssigner sees events.
By changing the parallelism between the map and the assigner, the events are shuffled across and hence there is no "empty" partition anymore.
I would check if one instance of your sources does not emit events.
2018-04-25 10:43 GMT+02:00 Timo Walther <twalthr@xxxxxxxxxx>: