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

2018-11-07 Thread Till Rohrmann
-------- >> *发件人:* Chesnay Schepler >> *发送时间:* Wednesday, September 5, 2018 3:23:23 PM >> *收件人:* 潘 功森; vino yang; d...@flink.apache.org >> *抄送:* user >> *主题:* Re: 答复: Flink1.6.0 submit job and got "No content to map due to >> end-of-input&qu

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

2018-10-26 Thread Jeroen Steggink | knowsy
led.It confused me a lot. *发件人:* Chesnay Schepler 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 "

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

2018-09-05 Thread Chesnay Schepler
yang *发送时间:* Wednesday, September 5, 2018 10:35:59 AM *收件人:* 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

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

2018-09-04 Thread 潘 功森
tps://go.microsoft.com/fwlink/?LinkId=550986>应用 发件人: vino yang 发送时间: Wednesday, September 5, 2018 10:35:59 AM 收件人: 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 u

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

2018-09-04 Thread 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. ? ?? 于2018年9月4日周二 下午10:07写道: > Hi all, > I use below way to submit jar to Flink : > > StreamExecutionEnvironment env =

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

2018-09-04 Thread ? ??
Hi all, I use below way to submit jar to Flink : StreamExecutionEnvironment env = StreamExecutionEnvironment.createRemoteEnvironment(config.clusterIp, config.clusterPort,