value must use all data.so is there some
operate can set the step 3 start when step 2 is end.
- 原始邮件 -
发件人:"Tzu-Li (Gordon) Tai"
收件人:rimin...@sina.cn
主题:Re: flink one transformation end,the next transformation start
日期:2017年03月30日 15点54分
Hi,
What exactly is the error you’re runni
What is the error message/stack trace you get here?
On Thu, Mar 30, 2017 at 9:33 AM, wrote:
> hi,all,
> i run a job,it is :
> -
> val data = env.readTextFile("hdfs:///")//DataSet[(String,Array[String])]
> val dataVec =
> computeDataVect