LinkedIn
Twitter
I'm testing dataflow for 1 MongoDB document. It moves through the different steps of the pipeline. In the UI I can see, for a specific step, how many elements (1 in this case) were added and how many (again, 1) were at the output. But, that is not happening when I'm using beam.Flatten. I would expect to return that 1 document. The step after flatten (Export Results), which is a ParDo, shows 0 element at the input.
I'm using Python 3.8 SDK 2.37.0
