You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Rahul Teke (Jira)" <ji...@apache.org> on 2025/10/31 17:58:00 UTC

[jira] [Created] (FLINK-38606) Support Flink Mongodb connector on latest version of Flink 2.1.0

Rahul Teke created FLINK-38606:
----------------------------------

             Summary: Support Flink Mongodb connector on latest version of Flink 2.1.0
                 Key: FLINK-38606
                 URL: https://issues.apache.org/jira/browse/FLINK-38606
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / MongoDB
            Reporter: Rahul Teke


Below changes are required for support flink version 2.1.0
 
*Mongo Source:*
API change for SingleThreadFetcherManager constructor to remove FutureCompletingBlockingQueue. This is now created internally by SingeThreadFetcherManager using Configuration for queue capacity.
 
*Mongo Sink:*
Migrate from InitContext to WriterInitContext (API change in flink 2.x)
 
Both of the above changes are driven from API changes well documented on flink release notes.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)