I think there is a problem with the interaction of legacy OutputFormats and
streaming programs. Flush is not called, the CsvOutputFormat only writes in
flush(), therefore we don't see any results.
On Mon, 2 May 2016 at 11:59 Fabian Hueske wrote:
> Have you checked the log files as well?
>
> 2016
Have you checked the log files as well?
2016-05-01 14:07 GMT+02:00 subash basnet :
> Hello there,
>
> If anyone could help me know why the below *result* DataStream get's
> written as text, but not as csv?. As it's in a tuple format I guess it
> should be the same for both text and csv. It shows
Hello there,
If anyone could help me know why the below *result* DataStream get's
written as text, but not as csv?. As it's in a tuple format I guess it
should be the same for both text and csv. It shows no error just simply
doesn't write to file when result is written as csv.
DataStream> *result
Hello all,
I am able to write the Wikipedia edit data to the kafka and as a text file
as per the given example of WikipediaAnalysis. But when I try to write it
as csv, the blank files initially created never gets filled with data.
Below is the code:
DataStream> result =
keyedEdits.timeWindow(Time
