Hi Jeroen, could you maybe share the Flink logs with us to further debug the problem?
Cheers, Till On Fri, Oct 26, 2018 at 3:56 PM Jeroen Steggink | knowsy <jer...@knowsy.nl> wrote: > Hi, > > I'm running Flink 1.5.4 and all dependencies in the job rely on 1.5.4. > However, I still get this error. According to the JIRA issue it should be > fixed in 1.5.4 as well. > > Since I'm using Apache Beam to build the jar, I can't move to version > 1.6.x. > > What could it be? > > Cheers, > > Jeroen > On 07-Sep-18 17:52, Till Rohrmann wrote: > > 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; d...@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 >> *收件人:* 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> 于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 >>> >>> >> >
