I figured out that the problem is with the local runner. Once I deploy the pipeline to Dataflow everything works as expected. Does anyone have an idea what might be the issue when running locally? It's tedious to debug a complicated pipeline if I can't do it locally.
Thanks, Matyas On Tue, 29 Mar 2022 at 14:45, Mátyás Manninger <[email protected]> wrote: > Dear Users, > > I am looking for some help on this issue I am having when testing a side > input pattern locally. Here is my StackOverflow question for reference: > https://stackoverflow.com/questions/71648731/fixedwindow-apparently-not-firing-in-streaming-python-beam-pipeline > As mentioned there I am trying to achieve the first side input pattern > mentioned here: > https://beam.apache.org/documentation/patterns/side-inputs/. This does > not have a python code sample, is this because it's not supposed to work in > python? > I am very thankful for any help, tips, pointers :) > > Best regards, > Matyas Manninger >
