Re: java.io.FileNotFoundException in implementing exactly once

2019-06-11 Thread zhijiang
For exactly-once mode before flink-1.5, it needs the temp dir for spilling the blocking buffers during checkpoint. The temp dir is configured via `io.tmp.dirs` and the default value is `java.io.tmpdir`. In your case, your temp dir prefix with `/tmp/` has some problems (might be deleted), and yo

java.io.FileNotFoundException in implementing exactly once

2019-06-11 Thread syed
Hi; I am trying to run the standard WordCount application under exactly once and at-least once processing guarantees, respectively. I successfully run the at-least once guarantee, however which running the exactly once guarantee, I face the following exception *Root exception:* java.io.FileNotFound