Hi, Do you have a requirement to continuously prioritise one input source over another (like always read topic X from Kafka before topic Y from Kafka) or is it a one-time effort, because you might need to bootstrap some state, so first read all data from file source A before switching over to topic B from Kafka?). If it's the latter, you could look into the HybridSource.
Best regards, Martijn On Tue, 23 Nov 2021 at 15:34, Shazia Kayani <shazia.kay...@ibm.com> wrote: > 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 > > 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 > > >
