thanks Hequn.
When I use as suggested, I am getting this error
error]
/home/hduser/dba/bin/flink/md_streaming/src/main/scala/myPackage/md_streaming.scala:30:
not found: value FileSystem
[error] .writeAsText("/tmp/md_streaming.txt",
FileSystem.WriteMode.OVERWRITE)
[error] ^
[error] one error found
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.
On Tue, 3 Jul 2018 at 03:16, Hequn Cheng <chenghe...@gmail.com> wrote:
> 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.
>>
>>
>>
>
>
