Hi, I've been trying to write an integration test for my Flink application that has managed state with TTL expiration.
However, I can't seem to find a good way to create a stream of elements that waits X amount of time before each element is sent in. I'm using the simple API: val stream = env.fromElements( ... ... ) Is there a way to do this? E.g. I'd like to wait 5 seconds before sending in the next element to see if the managed state expiration is working. Thanks, Yee-Ning
