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
