I had to restart the flink process. That fixed the issue Sent from my iPhone
> On Sep 1, 2017, at 3:39 PM, ant burton <apburto...@gmail.com> wrote: > > Is this of any help > > https://stackoverflow.com/questions/33890759/how-to-specify-overwrite-to-writeastext-in-apache-flink-streaming-0-10-0 > > fs.overwrite-files: true in your flink-conf.yaml > > >> On 1 Sep 2017, at 23:36, Krishnanand Khambadkone <kkhambadk...@yahoo.com> >> wrote: >> >> I am trying to submit a flink job from the command line and seeing this >> error. Any idea what could be happening >> >> java.io.IOException: File or directory already exists. Existing files and >> directories are not overwritten in NO_OVERWRITE mode. Use OVERWRITE mode to >> overwrite existing files and directories. >> >