Hi Thomas, Sorry for later reply for your POC. I have reviewed the based abstract implementation of your pull request: https://github.com/apache/flink/pull/15924. IMO, for the switching mechanism, this level of abstraction is not concise enough, which doesn't make connector contribution easier. In theory, it is necessary to introduce a set of interfaces to support the switching mechanism. The SwitchableSource and SwitchableSplitEnumerator interfaces are needed for connector expansibility. In other words, the whole switching process of above mentioned PR is different from that mentioned in FLIP-150. In the above implementation, the source reading switching is executed after receving the SwitchSourceEvent, which could be before the sending SourceReaderFinishEvent. This timeline of source reading switching could be discussed here. @Stephan @Becket, if you are available, please help to review the abstract implementation, and compare with the interfaces mentioned in FLIP-150.
Thanks, Nicholas Jiang -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
