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)
