Error submitting flink job

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Error submitting flink job

Krishnanand Khambadkone
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.


Reply | Threaded
Open this post in threaded view
|

Re: Error submitting flink job

ant burton
Is this of any help


fs.overwrite-files: true in your flink-conf.yaml


On 1 Sep 2017, at 23:36, Krishnanand Khambadkone <[hidden email]> 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.


Reply | Threaded
Open this post in threaded view
|

Re: Re: Error submitting flink job

Krishnanand Khambadkone
I have set this in my flink-conf.yaml file.

On Friday, September 1, 2017, 3:39:05 PM PDT, ant burton <[hidden email]> wrote:


Is this of any help


fs.overwrite-files: true in your flink-conf.yaml


On 1 Sep 2017, at 23:36, Krishnanand Khambadkone <[hidden email]> 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.


Reply | Threaded
Open this post in threaded view
|

Re: Error submitting flink job

Krishnanand Khambadkone
In reply to this post by ant burton
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 <[hidden email]> wrote:

Is this of any help


fs.overwrite-files: true in your flink-conf.yaml


On 1 Sep 2017, at 23:36, Krishnanand Khambadkone <[hidden email]> 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.