Hello 👋 Question about the Flink AsyncIO. In my DAG. I have two Flink AsyncIO operators (say Op1 & Op2), and both are using unordered wait, and by default, Flink chains them together. In this case, whether Flink will guarantee to invoke Op2 after Op1 completion/failure for an event (E1), or can we expect Op1 and Op2 to trigger at the same time for event E1?

If they're different operators in your dag,

Op2

will process

E1

only when

Op1

`collects`/forwards it.