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
