Re: Job fails with FileNotFoundException from blobStore

2015-02-05 Thread Robert Waury
I compiled from the release-0.8 branch. On Thu, Feb 5, 2015 at 8:55 AM, Stephan Ewen se...@apache.org wrote: Hey Robert! On which version are you? 0.8 or 0.9- SNAPSHOT? Am 04.02.2015 14:49 schrieb Robert Waury robert.wa...@googlemail.com: Hi, I'm suddenly getting FileNotFoundExceptions

Re: Get 1 element of DataSet

2015-02-05 Thread Vinh June
Hi Stefan, DataSet.first(n) produces a child DataSet, while I need the element Specifically, I have a CSV with header line and I want to make the maps of each (header,value) pair for each line -- View this message in context:

Re: Job fails with FileNotFoundException from blobStore

2015-02-05 Thread Robert Waury
I talked with the admins. The problem seemed to have been that the disk was full and Flink couldn't create the directory. Maybe the the error message should reflect if that is the cause. While cleaning up the disk we noticed that a lot of temporary blobStore files were not deleted by Flink after

Re: Get 1 element of DataSet

2015-02-05 Thread Stefan Bunk
Hi Vinh, have a look at the first function: http://flink.apache.org/docs/0.8/dataset_transformations.html#first-n Stefan On 5 February 2015 at 15:14, Vinh June hoangthevinh@gmail.com wrote: Hi, Is there any way to get 1 element of a DataSet, for example:

Re: Job fails with FileNotFoundException from blobStore

2015-02-05 Thread Stephan Ewen
I think that process killing (HALT signal) is a very typical way in Linux to shut down processes. It is the most robust way, since it does not require to send any custom messages to the process. This is sort of graceful, as the JVM gets the signal and may do a lot of things before shutting down,