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 disabled as it is currently not supported.
I was just wondering if anyone has done something similar to this previously? and if so were you able to implement changes which resulted in successful checkpointing?
If anyone has any other tips around the topic that too would also be helpful!
Thanks
Shazia
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 disabled as it is currently not supported.
I was just wondering if anyone has done something similar to this previously? and if so were you able to implement changes which resulted in successful checkpointing?
If anyone has any other tips around the topic that too would also be helpful!
Thanks
Shazia
Unless stated otherwise above:
IBM United Kingdom Limited - Registered in England and Wales with number 741598.
Registered office: PO Box 41, North Harbour, Portsmouth, Hampshire PO6 3AU
