@Jason I think there's a mistake in your explanation since each task in the task manager has its own copy of an operator instance, so the tuple may not be shared. State is a great solution but I think that's not the root cause.
@Tarek What's the parallelism of your data stream? I think the reason may be the parallelism is 1. On Thu, May 4, 2017 at 10:39 PM Tarek khal <tarek.khal.leta...@gmail.com> wrote: > Hi Jason, > > Thank you very much for your help, it solves my problem. > > Best regards, > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13003.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. > -- Liu, Renjie Software Engineer, MVAD
