neoneo008 opened a new pull request, #57:
URL: https://github.com/apache/flink-connector-mongodb/pull/57
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 is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
