+1 (non-binding)
--
Best！
Xuyang
在 2024-01-19 10:16:23，"Qingsheng Ren" <[email protected]> 写道：
>+1 (binding)
>
>Thanks for the work, Hongshun!
>
>Best,
>Qingsheng
>
>On Tue, Jan 16, 2024 at 11:21 AM Leonard Xu <[email protected]> wrote:
>
>> Thanks Hongshun for driving this !
>>
>> +1(binding)
>>
>> Best,
>> Leonard
>>
>> > 2024年1月3日 下午8:04，Hongshun Wang <[email protected]> 写道：
>> >
>> > 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
>>
>>
