Hey Robert, is this error reproducible?
I've looked into the blob store and the error occurs when the blob cache tries to *create* a local file before requesting it from the job manager. I will add a check to the blob store to ensure that the parent directories have been created. Other than that, I currently have no clue what the problem might be. Can you verify whether the parent directory has been created on your machines? You could do this before you submit the tasks. I will add the respective log messages to the blob cache and push to 0.8/master. – Ufuk On 05 Feb 2015, at 09:27, Robert Waury <robert.wa...@googlemail.com> wrote: > 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 because the blobStore cannot find > files in /tmp > > The job used work in the exact same setup (same versions, same cluster, same > input files). > > Flink version: 0.8 release > HDFS: 2.3.0-cdh5.1.2 > > Flink trace: > http://pastebin.com/SKdwp6Yt > > Any idea what could be the reason behind this? > > Cheers, > Robert >
