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.
>

Reply via email to