you!
>
> Best wishes,
>
> Shazia
>
>
> - Original message -
> From: "Piotr Nowojski"
> To: "Shazia Kayani"
> Cc: mart...@ververica.com, "user"
> Subject: [EXTERNAL] Re: Input Selectable & Checkpointing
> Date: Wed, Nov
mething which has a requirement from flink to prioritise one input datastream over another, to do this I'm currently implemented an operator which extends InputSelectable to do this.However, because of using input selectable checkpointing is disabled as it is currently not supported.I was j
there consistently being significantly more messages on one source
> than another which causes issues when we there are too many messages on the
> stream.
>
> Thanks
>
> Shazia
>
>
> - Original message -
> From: "Martijn Visser"
> To: "Shazia Ka
to prioritise one input datastream over another, to do this I'm currently implemented an operator which extends InputSelectable to do this.However, because of using input selectable checkpointing is disabled as it is currently not supported.I was just wondering if anyone has done something simi
e input datastream over another, to do this I'm currently implemented an
> operator which extends InputSelectable to do this.
> However, because of using input selectable checkpointing is disabled as it
> is currently not supported.
>
> I was just wondering if anyone has done someth
Hi All,Hope you are well!I am working on something which has a requirement from flink to prioritise one input datastream over another, to do this I'm currently implemented an operator which extends InputSelectable to do this.However, because of using input selectable checkpointing is disabl