Yes, if you use KeyedCoProcess, flink will ensure that.

Qihua Yang <yang...@gmail.com> 于2021年6月4日周五 上午12:32写道:
>
> 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

Reply via email to