Hey Rahul, I’ve asked Jiabao to help review this PR via private channel, hope it works.
Best, Leonard > 2025 11月 19 20:10，Rahul Teke <[email protected]> 写道： > > Can anyone help with review? > > Regards, > Rahul Teke > > > On Thu, 13 Nov 2025 at 17:45, Rahul Teke <[email protected]> wrote: > >> 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 >>>>>> >>>> >>>>
