Re: 回复:Re: flink one transformation end,the next transformation start

2017-03-31 Thread Tzu-Li (Gordon) Tai
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

Re: flink one transformation end,the next transformation start

2017-03-31 Thread Ufuk Celebi
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