答复: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired?

2018-04-25 Thread 潘 功森
I got you. Thanks! 发件人: 周思华 发送时间: 2018年4月26日 10:50 收件人: TechnoMage 抄送: Fabian Hueske; Timo Walther; user; 潘 功森 主题: Re: Why a

答复: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired?

2018-04-25 Thread 潘 功森
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 发送时间: 2018年4月25日 10:56 收件人: Timo Walther 抄送: user 主题: Re: Why assignTimestampsAndWatermarks parallelism same as

答复: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired?

2018-04-25 Thread 潘 功森
Yes. 发件人: Timo Walther 发送时间: 2018年4月25日 8:43 收件人: user@flink.apache.org 主题: Re: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Hi, did you set your time characteristics to even-time? env.setStreamTimeCharacteristic(TimeCharacteri