+1 (non-binding)
-- Best! Xuyang 在 2024-01-19 10:16:23,"Qingsheng Ren" <re...@apache.org> 写道: >+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 >> >>