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

@01D44531.7E8AB2C0] 发件人: Chesnay Schepler 发送时间: Wednesday, September 5, 2018 3:23:23 PM 收件人: 潘 功森; vino yang; dev@flink.apache.org 抄送: user 主题: Re: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Did you upgrade both the client and

答复: 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？

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 f