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 >>> >> >>> >>>
