Hi Gongsen, Chesnay found and fixed the problem: https://issues.apache.org/jira/browse/FLINK-10293.
Cheers, Till On Wed, Sep 5, 2018 at 10:00 AM 潘 功森 <pangong...@hotmail.com> wrote: > Hi Chesney, > > I can sure the client and cluster all upgraded to 1.6.0 cause if I > used “./flink run XXX.jar” to submit a job and it works fine.You can see ui > below. > > But when I used createRemoteEnvironment at local, and it failed.It > confused me a lot. > > > > > ------------------------------ > *发件人:* Chesnay Schepler <ches...@apache.org> > *发送时间:* 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 cluster to 1.6.0? The server returned > a completely empty response which shouldn't be possible if it runs 1.6.0. > > On 05.09.2018 07:27, 潘 功森 wrote: > > 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 > > > > 发送自 Windows 10 版邮件 <https://go.microsoft.com/fwlink/?LinkId=550986>应用 > > > ------------------------------ > *发件人:* vino yang <yanghua1...@gmail.com> <yanghua1...@gmail.com> > *发送时间:* Wednesday, September 5, 2018 10:35:59 AM > *收件人:* dev@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> 于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 >> >> >
