Hi group, What is the best practice for testing CoFlatMap operator correctness? We have two source functions, each emits data to stream, and a connect between them, and I want to make sure that when streamA element arrive before stream element, a certain behavior happens. How can I test this case?
Using env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); and emitting timestamp and watermark per element didn't help, and still each element arrive in unexpected order. Thanks in advance, Tovi
