Hi, Here are some of the queries I have :
I have two different streams stream1 and stream2 in which the elements are in order. 1) Now when I do keyBy on each of these streams, will the order be maintained ? (Since every group here will be sent to one task manager only ) My understanding is that the records will be in order for a group, correct me here 2) After the keyBy on both of the streams I am doing co-group to get the matching and non-matching records. Will the order be maintained here also ?, since this also works on KeyedStream. I am using EventTime, and AscendingTimestampExtractor for generating timestamp and watermark. 3) Now I want to perform the sequence check on the matching_nonMatchingStream I get from 2) using map/flatmap. Do I need to again perform the keyBy here , or if I keep in chain will the matching_nonMatchingStream run in same TaskManager ? My understanding here is that the chain will work here, correct me , getting confused. 4) slotSharingGroup - can you please describe more about this according to the doc : Sets the slot sharing group of this operation. Parallel instances of operations that are in the same slot sharing group will be co-located in the same TaskManager slot, if possible. Regards, Vinay Patil -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Discuss-Ordering-of-Records-tp7933.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
