[
https://issues.apache.org/jira/browse/FLINK-38606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18040156#comment-18040156
]
Rahul Teke commented on FLINK-38606:
------------------------------------
The kyro init strategy need to change to default with fallback to always call
no args constructor.
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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)
