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

[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
>>>
>>>
>>
>