Hi Lasse, Have you seen this approach https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/testing/#unit-testing-stateful-or-timely-udfs--custom-operators ?
On Tue, Apr 9, 2024 at 7:09 AM Lasse Nedergaard < lassenedergaardfl...@gmail.com> wrote: > Hi. > > I my Integration test, running on 1.19, with a mini cluster I mock all my > sources with DataGeneratorSource and it works fine until I have a timer > function in a key processed function. > The problem is that the processing time doesn’t advance after all data has > been produced in the sources. > so I’m looking for a solution where I can advance the processing and the > onTimer method get called. > Any one who knows how to do that or a nice workaround. > > > Med venlig hilsen / Best regards > Lasse Nedergaard > >
