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 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用 ________________________________ 发件人: vino yang <yanghua1...@gmail.com> 发送时间: Wednesday, September 5, 2018 10:35:59 AM 收件人: d...@flink.apache.org 抄送: user 主题: Re: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Hi Pangongsen, Do you upgrade the Flink-related dependencies you use at the same time? In other words, is the dependency consistent with the flink version? Thanks, vino. ? ?? <pangong...@hotmail.com<mailto:pangong...@hotmail.com>> 于2018年9月4日周二 下午10:07写道： Hi all, I use below way to submit jar to Flink : StreamExecutionEnvironment env = StreamExecutionEnvironment.createRemoteEnvironment(config.clusterIp, config.clusterPort, config.clusterFlinkJar); I used Flink 1.3.2 before, and it works fine. But I upgrade it to 1.6.0, and I got the error below: 2018-09-04 21:38:32.039 [ERROR] [flink-rest-client-netty-19-1] org.apache.flink.runtime.rest.RestClient - Unexpected plain-text response: 2018-09-04 21:38:32.137 [ERROR] [flink-rest-client-netty-18-1] org.apache.flink.runtime.rest.RestClient - Response was not valid JSON. org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException: No content to map due to end-of-input Could you give me some advice to fix it? yours, Gongsen
