Sorry for the confusion.... Yes, I mean multiple parallelism. Really thanks for your help.
Thanks, Qihua On Thu, Jun 3, 2021 at 12:03 AM JING ZHANG <beyond1...@gmail.com> wrote: > Hi Qihua, > > I’m sorry I didn’t understand what you mean by ‘replica’. Would you please > explain a little more? > If you means you job has multiple parallelism, and whether same data from > different two inputs would be send to the same downstream subtask after > `keyedCoProcessFunction`. > Yes, Flink could do this, if you keyBy the same field for two inputs. > > Best regards, > JING ZHANG > > Qihua Yang <yang...@gmail.com> 于2021年6月3日周四 下午12:25写道： > >> Hi, >> >> I have a question. We have two data streams that may contain duplicate >> data. We are using keyedCoProcessFunction to process stream data. I defined >> the same keySelector for both streams. Our flink application has multiple >> replicas. We want the same data to be processed by the same replica. Can >> flink ensure that? >> >> Thanks, >> Qihua >> >
