Hi Rohit,
it depends a little bit on your tests. If you test individual operators you
can use the AbstractStreamOperatorTestHarness class which allows to set the
processing time via AbstractStreamOperatorTestHarness#setProcessingTime.
You can also set the ProcessingTimeService used by a StreamTask
Hi,
I am writing tests for my flink streaming application. I mostly use
event-time. But there are some aspects which are still controlled by
wall-clock time. For example, I am using AssignerWithPeriodicWatermarks and
so watermarks are triggered based on wall-clock time. Similarly,
checkpoints are
