Hello Team!, I running a flink job in BATCH mode, Basically we are consuming from 3 sources. We have logic based on the order of the events it is read from the kafka for STREAM layer. The same logic we are using for the BATCH. In Stream we can pridict the order using Watermark. In case of BATCH layer sources read in different order. Note all the 3 sources have same key. How to sort the payload before moving to the next operator in BATCH?