You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by Claire Yuan <cl...@yahoo-inc.com> on 2017/07/21 00:02:08 UTC

How to write the streaming output into csv file

Hi all,  I am currently running a streaming data processing pipeline using Beam in flink runner. I passed my records along my pipeline with a window of 1 minutes applied to it. I use the code from the TfIdf example to write output into local csv file. However it seems like the pipeline never reaches the sink. There is no output file produced while my pipeline running no matter how many time passed. Would anyone give suggestion on how to solve this?
Claire