Hi. After upgrading from 1.18 to either 1.19 or 1.20 onTimer don’t fire in one of our classes that extends KeyedProcessFunction when executing texts running on mini cluster.
If I add a breakpoint in InternalTimeServiceImpl line 126 the callback is executed but without a breakpoint it doesn’t work and no callback. The same happens if I just run the test. As part of our upgrade I have replaced our test SourceFunction’s used for mock and replaced it with Source<> But besides that change I can’t see any difference. Anyone have some suggestions to further debugging? Med venlig hilsen / Best regards Lasse Nedergaard
