Hey, Rahul

Thanks for the contribution, I’ll try to ping some committers who’re familiar 
with MongoDB, but it depends on their time slot.

Best,
Leonard

> 2025 11月 11 01:46,Rahul Teke <[email protected]> 写道:
> 
> Hello everyone,
> 
> Can someone help review the Pull request for support flink 2.x for mongodb
> connector?
> 
> 
> On Thu, 6 Nov 2025 at 20:34, Rahul Teke <[email protected]> wrote:
> 
>> I've created a JIRA ticket FLINK-38606
>> <https://issues.apache.org/jira/browse/FLINK-38606> for adding flink
>> 2.1.0 support to the flink mongodb connector.
>> I've raise a pull request with the JIRA ticket as well 
>> [FLINK-38606][Connectors/MongoDB]
>> Support for Flink 2.1.0 API by neoneo008 · Pull Request #57 ·
>> apache/flink-connector-mongodb
>> <https://github.com/apache/flink-connector-mongodb/pull/57>
>> 
>> Below changes are required for support
>> 
>> Source:
>> API change for SingleThreadFetcherManager constructor to remove
>> FutureCompletingBlockingQueue. This is now created internally by
>> SingeThreadFetcherManager using Configuration for queue capacity.
>> 
>> Sink:
>> Migrate from InitContext to WriterInitContext (API change in flink 2.x)
>> 
>> Can some help review? Happy to address any review comments or suggestions.
>> 
>> 
>> Best,
>> Rahul Teke
>> 

Reply via email to