Flink stream processing issue

[Qihua Yang]

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