Hi all, I struggle for some days now to get late data handling right for a custom UnboundedSource. I have the impression that late data gets not detected (i.e. it gets not dropped). The same pipeline returns different results when data is fed into by a TestStream or by my custom UnboundedSource.
I setup a small repo to illustrate the situation: https://github.com/swachter/beam-test Can someone give me some hints what I might be doing wrong? TIA Stefan
