Re: parallelism parameter and output relation

2016-01-21 Thread Serkan Taş
Hi Robert, I found the the real reason for the case. Sorry but missed that the example project was using 0.8.1. It is resolved after replacing with 0.10.1. > 20 Oca 2016 tarihinde 16:40 saatinde, Robert Metzger > şunları yazdı: > > Hi Serkan, > > yes, with parallelism=1, you'll get one fi

Re: parallelism parameter and output relation

2016-01-20 Thread Robert Metzger
Hi Serkan, yes, with parallelism=1, you'll get one file, with everything higher, Flink is creating a directory with a file for each parallel instance. In your case, Flink can not create (or write to) the file because there is already a directory with the same name. Can you delete the directory and

parallelism parameter and output relation

2016-01-20 Thread Serkan Taş
I am working on this example http://www.itshared.org/2015/03/naive-bayes-on-apache-flink.html to learn get some more experience on platform. Question is ; By default, the output of process is double file (named 1 and 2) located in created folder. If i set parallelism to 1, FileNotFound excepti