答复: No data issued by flink window after a few hours

gongsen, Have you used event time as time semantics? If so, then the possible problem is related to watermark. Since I don't know the details of your program, it's hard to make a conclusion. You can check if your watermark is firing normally. Thanks, vino. 潘 功森 mailto:pangong...@hotmail.com>

答复: No data issued by flink window after a few hours

Please look at the mail below, the others were out of data cause the bad network. Yours, September 发件人: 潘 功森 发送时间: Friday, October 12, 2018 11:05:49 AM 收件人: vino yang 抄送: user 主题: 答复: No data issued by flink window after a few hours Hi, I found the pictures

答复: 答复: No data issued by flink window after a few hours

The second question looks fine. [cid:image004.png@01D461B6.93D6FF70] Yours, September 发件人: Dawid Wysakowicz<mailto:dwysakow...@apache.org> 发送时间: 2018年10月11日 15:13 收件人: 潘 功森<mailto:pangong...@hotmail.com>; vino yang<mailto:yanghua1...@gmail.com> 抄送: user<mailto:user@flink.a

答复: No data issued by flink window after a few hours

Hi， I changed as below configurations，and it looks fine when job started. But there’re no results issued when window ends after running about six hours, and no errors and exceptions. How can I position the question? Yours, September 发件人: 潘 功森 发送时间: Wednesday

答复: No data issued by flink window after a few hours

= new MemoryStateBackend(theSizeOfBytes); Please note that you need to reserve enough memory for Flink. Thanks, vino. 潘 功森 mailto:pangong...@hotmail.com>> 于2018年10月10日周三 上午11:36写道： Please have a look about my last mail. When the cached window data is too large, how? Yours, Sep

答复: No data issued by flink window after a few hours

Hi, "ram to cache the distinct data about sliding window" means I used computer momery not the third part db to cache the data need used in window. “the data need used in window” means ：such as the sliding window is 1 hour, and I need to count the distinct users, I need to cache the user id

答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error

Hi Vino， Below are dependencies I used，please have a look. I floud it also inclued flink-connector-kafka-0.10_2.11-1.6.0.jar and flink-connector-kafka-0.9_2.11-1.6.0.jar, and I don’t know if it has any effect? yours, Gongsen [cid:image001.png@01D4451B.3D5B1580] 发送自 Windows 10

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

I got you. Thanks！ 发件人: 周思华<mailto:summerle...@163.com> 发送时间: 2018年4月26日 10:50 收件人: TechnoMage<mailto:mla...@technomage.com> 抄送: Fabian Hueske<mailto:fhue...@gmail.com>; Timo Walther<mailto:twal...@apache.org>; user<mailto:user@flink.apache.org>; 潘 功森<mailto:pa

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

et 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 g

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

n-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 waterm

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