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 >
