There is a parallel thread answering the questions going on here already: http://stackoverflow.com/questions/38354713/ordering-of-records-in-stream
On Tue, Jul 12, 2016 at 7:12 PM, vinay patil <vinay18.pa...@gmail.com> wrote: > 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. >
