Hey Radu,
As you are using the streaming api I assume that you call env.execute() in
both cases. Is that the case?
Do you see any errors appearing? My first call would be if your data type
is not a tuple type then writeAsCsv does not work by default.
Best,
Marton
On Thu, Feb 4, 2016 at 11:36 AM, Radu Prodan <raduprod...@gmail.com> wrote:
> 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
>
>
>
>
>
>
