flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Radu Prodan <raduprod...@gmail.com>
Subject Flink writeAsCsv
Date Thu, 04 Feb 2016 10:36:17 GMT
Hi all,

I am new to flink. I wrote a simple program and I want it to output as csv
file.

timeWindowAll(Time.of(3, TimeUnit.MINUTES))

.apply(newFunction1())

.writeAsCsv("file:///user/someuser/Documents/somefile.csv");


When I change the sink to . print(), it works and outputs some results.

I want it to output the result of every window. However, it outputs nothing
and the file is not created. Am I missing anything?


-best

Radu

Mime
View raw message