Hi, This is not possible out-of-box, but you could use a ProcessFunction (or rather CoProcessFunction) to buffer elements and set a timer so that you only emit when the watermarks advances on both inputs.
Best, Aljoscha > On 28. Aug 2017, at 08:10, ziv <ziv.m...@elbitsystems.com> wrote: > > People, > > I have two sources: > > 1) DataStream<Integer> int1 = env.addSource(new intWithDelat1()): generates > series of integers in streaming of 1 sec delay between elemets. > > 2) DataStream<Long> long3 = env.addSource(new longWithDelay3()): generates > series of longs in streaming of 3 sec delay. > > I want to: > > int1.connect(long3).flatMap(new printElemnts()); > > I want this transformation to be synchronized so that element from source 1 > will be read only when the equivalent element from source 2 comes: > 1 > 1 > 2 > 2 > 3 > 3 > … > > And not: > 1 > 1 > 2 > 3 > 2 > 4 > 5 > … > > any way to do that? > > (advanced: why things not similar to the example in 'notions of time' > <https://www.youtube.com/watch?v=xiKsOocNkDA> at 11:20?) > > Thanks > > > > -- > View this message in context: > http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Sync-Flink-tp19403.html > Sent from the Apache Flink Mailing List archive. mailing list archive at > Nabble.com.
