Hi Tarek, This question seems to be a duplicate with your other question “ConnectedStream keyBy issues”, right? I am just asking for clarification.
Thanks, Kostas > On May 4, 2017, at 1:41 PM, Tarek khal <tarek.khal.leta...@gmail.com> wrote: > > Hi Aljoscha, > > I tested ConnectedStream and CoFlatMapFunction as you told me but the result > is not as I wait. > > > *For the execution:* > > 1) I added 3 rules on "rules" topic (imei: "01","02,"03") > 2) Perform 15 events with different imei but i guess i have problem with > "keyby" > > *Result : * > > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n12998/2222222.jpg> > > > Code : > > > Best, > > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Join-two-kafka-topics-tp12954p12998.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
