Hi Jiabo-Sun, Apologies for the build failure due to code formatting issues. Unfortunately, I didn't realise that spotless doesn't work on java 21. Have fixed the formatting issues and pushed a new commit.
*Breaking change alert: * Minimum JDK version requirement for Flink 2.x have changed to JDK 17. Reference: Apache Flink 2.0.0: A new Era of Real-Time Data Processing | Apache Flink <https://flink.apache.org/2025/03/24/apache-flink-2.0.0-a-new-era-of-real-time-data-processing/> This support PR would remove the support for Flink 1.x versions. I've modified the push_pr.yml accordingly. Regards, Rahul Teke On Tue, 11 Nov 2025 at 20:11, Rahul Teke <[email protected]> wrote: > Thanks, Leonard. Much appreciated. > > Looking forward for the review. > > Regards, > Rahul Teke > > > On Tue, 11 Nov 2025 at 01:58, Leonard Xu <[email protected]> wrote: > >> 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 >> >> >> >>
