You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Jeroen Steggink | knowsy <je...@knowsy.nl> on 2018/10/26 13:56:51 UTC
Re: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error
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 潘 功森 <pangongsen@hotmail.com
> <ma...@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 <chesnay@apache.org
> <ma...@apache.org>>
> *发送时间:* Wednesday, September 5, 2018 3:23:23 PM
> *收件人:* 潘 功森; vino yang; dev@flink.apache.org
> <ma...@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 <ya...@gmail.com>
>> <ma...@gmail.com>
>> *发送时间:* Wednesday, September 5, 2018 10:35:59 AM
>> *收件人:* dev@flink.apache.org <ma...@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 <ma...@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
>>
>
Re: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error
Posted by Till Rohrmann <tr...@apache.org>.
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 <je...@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 潘 功森 <pa...@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 <ch...@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 <ya...@gmail.com> <ya...@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.
>>
>> ? ?? <pa...@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
>>>
>>>
>>
>