Thanks Hongshun for driving this ! +1(binding)
Best, Leonard > 2024年1月3日 下午8:04，Hongshun Wang <loserwang1...@gmail.com> 写道： > > Dear Flink Developers, > > Thank you for providing feedback on FLIP-389: Annotate > SingleThreadFetcherManager as PublicEvolving[1] on the discussion > thread[2]. The goal of the FLIP is as follows: > > - To expose the SplitFetcherManager / SingleThreadFetcheManager as > Public, allowing connector developers to easily create their own threading > models in the SourceReaderBase by implementing addSplits(), removeSplits(), > maybeShutdownFinishedFetchers() and other functions. > - To hide the element queue from the connector developers and simplify > the SourceReaderBase to consist of only SplitFetcherManager and > RecordEmitter as major components. > > > Any additional questions regarding this FLIP? Looking forward to hearing > from you. > > > Thanks, > Hongshun Wang > > > [1] > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=278465498 > > [2] https://lists.apache.org/thread/b8f509878ptwl3kmmgg95tv8sb1j5987
