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
<mailto: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
<mailto:ches...@apache.org>>
*发送时间:* Wednesday, September 5, 2018 3:23:23 PM
*收件人:* 潘 功森; vino yang; d...@flink.apache.org
<mailto: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>
<mailto:yanghua1...@gmail.com>
*发送时间:* Wednesday, September 5, 2018 10:35:59 AM
*收件人:* d...@flink.apache.org <mailto: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 <mailto: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
