Hi Mich,
It seems the writeMode has not been set correctly. Have you ever tried
> .writeAsText("/tmp/md_streaming.txt", FileSystem.WriteMode.OVERWRITE);
On Mon, Jul 2, 2018 at 10:44 PM, Mich Talebzadeh <mich.talebza...@gmail.com>
wrote:
> Flink 1.5
>
> This streaming data written to a file
>
> val stream = env
> .addSource(new FlinkKafkaConsumer09[String]("md", new
> SimpleStringSchema(), properties))
> .writeAsText("/tmp/md_streaming.txt")
> env.execute("Flink Kafka Example")
>
> The error states
>
> Caused by: java.io.IOException: File or directory /tmp/md_streaming.txt
> already exists. Existing files and directories are not overwritten in
> NO_OVERWRITE mode. Use OVERWRITE mode to overwrite existing files and
> directories.
>
> Is there any append in writeAsText? I tried OVERWRITE but did not work.
>
> Thanks
>
> Dr Mich Talebzadeh
>
>
>
> LinkedIn *
> https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw
> <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>*
>
>
>
> http://talebzadehmich.wordpress.com
>
>
> *Disclaimer:* Use it at your own risk. Any and all responsibility for any
> loss, damage or destruction of data or any other property which may arise
> from relying on this email's technical content is explicitly disclaimed.
> The author will in no case be liable for any monetary damages arising from
> such loss, damage or destruction.
>
>
>
