+1 (binding) Thanks for the work, Hongshun!
Best, Qingsheng On Tue, Jan 16, 2024 at 11:21 AM Leonard Xu <xbjt...@gmail.com> wrote: > 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 > >
