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

[潘 功森]

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

 

[vino yang]

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.

? ?? <[hidden email]> 于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

[潘 功森]

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 版邮件应用

 

---

发件人: vino yang <[hidden email]>
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: [hidden email]
抄送: 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.

? ?? <[hidden email]> 于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

[Chesnay Schepler]

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 版邮件应用

 

---

发件人: vino yang [hidden email]
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: [hidden email]
抄送: 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.

? ?? <[hidden email]> 于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

[潘 功森]

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 <[hidden email]>
发送时间: Wednesday, September 5, 2018 3:23:23 PM
收件人: 潘 功森; vino yang; [hidden email]
抄送: 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 版邮件应用

 

---

发件人: vino yang [hidden email]
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: [hidden email]
抄送: 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.

? ?? <[hidden email]> 于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

[Till Rohrmann]

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 潘 功森 <[hidden email]> 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 <[hidden email]>
发送时间: Wednesday, September 5, 2018 3:23:23 PM
收件人: 潘 功森; vino yang; [hidden email]
抄送: 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 版邮件应用

 

---

发件人: vino yang [hidden email]
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: [hidden email]
抄送: 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.

? ?? <[hidden email]> 于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

[Jeroen Steggink | knowsy]

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 潘 功森 <[hidden email]> 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 <[hidden email]>
发送时间: Wednesday, September 5, 2018 3:23:23 PM
收件人: 潘 功森; vino yang; [hidden email]
抄送: 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 版邮件应用

 

---

发件人: vino yang [hidden email]
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: [hidden email]
抄送: 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.

? ?? <[hidden email]> 于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

[Till Rohrmann]

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 <[hidden email]> 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 潘 功森 <[hidden email]> 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 <[hidden email]>
发送时间: Wednesday, September 5, 2018 3:23:23 PM
收件人: 潘 功森; vino yang; [hidden email]
抄送: 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 版邮件应用

 

---

发件人: vino yang [hidden email]
发送时间: Wednesday, September 5, 2018 10:35:59 AM
收件人: [hidden email]
抄送: 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.

? ?? <[hidden email]> 于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