Testing Flink Streaming applications - controlling the clock

Posted by Rohit Agarwal on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Testing-Flink-Streaming-applications-controlling-the-clock-tp10569.html

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 also triggered based on wall-clock time. Is there a way I can manually control the clock which flink uses from my tests.

--

Rohit Agarwal