1. The timestamp passed to testHarness.processElement should be the
timestamp that would have been extracted from the element by the
timestamp extractor in your watermark strategy.
2. Your tests should call testHarness.processWatermark and pass in the
watermark(s) you want to work with.
processBr
Hello dear Flink team
We are rather new to Flink and having problems understanding how unit
testing works overall.
We want to test the* onTimer()* method after registering a timer in the
*processElement()* function. However, the *onTimer() *is never called.
We were investigating the documentation
