flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 潘 功森 <pangong...@hotmail.com>
Subject 答复: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error
Date Wed, 05 Sep 2018 08:00:02 GMT
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.

[cid:image002.png@01D44531.7E8AB2C0]

________________________________
发件人: Chesnay Schepler <chesnay@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
[cid:part1.D07B7746.384922CF@apache.org]

发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用

________________________________
发件人: vino yang <yanghua1127@gmail.com><mailto:yanghua1127@gmail.com>
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: dev@flink.apache.org<mailto: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.

? ?? <pangongsen@hotmail.com<mailto:pangongsen@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


Mime
View raw message