Has anyone done invariant testing in Flink? I want to wrist tests for stateful operators where the program might have some invariants for a period of time, then the invariants might be change. Either way, I want to be checking invariants after actions like timers being fired or processing elements