[
https://issues.apache.org/jira/browse/FLINK-38606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-38606.
--------------------------------
Resolution: Fixed
[{{e03d336}}|https://github.com/apache/flink-connector-mongodb/commit/e03d33635cb3901ef85f768c7a02d21fc4c5505f]
on main
> Update MongoDB connector to 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
> Assignee: Rahul Teke
> Priority: Minor
> Labels: pull-request-available
> Fix For: mongodb-2.1.0
>
>
> 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)
