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.

Reply via email to