Hi Abdul,
the DataStream#writeAsText does not support a TextFormatter as argument.
You either have to implement your own OutputFormat and calling
DataStream#writeUsingOutputFormat or as Fabio recommended simply use
DataStream#writeAsCsv.
Cheers,
Till
On Fri, Apr 28, 2017 at 11:46 AM, Fábio Dia
Hi,
Instead of use writeAsText you have a writeAsCsv
https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/datastream/DataStream.html
You can use just with the string path (like you have) or you can use the
overwrite flag if it suit your needs.
Best Regar
