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
