flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From subash basnet <yasub...@gmail.com>
Subject override file in flink
Date Tue, 22 Mar 2016 11:18:12 GMT
Hello all,

I am trying to write the streaming data to file and update it recurrently
with the streaming data. I get the following unable to override exception
error:

*Caused by: 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.*
at
org.apache.flink.core.fs.FileSystem.initOutPathLocalFS(FileSystem.java:594)
at
org.apache.flink.api.common.io.FileOutputFormat.open(FileOutputFormat.java:227)
at
org.apache.flink.api.java.io.CsvOutputFormat.open(CsvOutputFormat.java:160)
at
org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction.open(OutputFormatSinkFunction.java:60)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38)
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:314)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:214)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)



How to set the necessary override property?

Best Regards,
Subash Basnet

Mime
View raw message