[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607404#comment-17607404
]
Martijn Visser commented on FLINK-6573:
---------------------------------------
[~arvid] Thanks for the ping
[~jiabao.sun] Thanks for reaching out! Great to hear that you would like to
introduce a new connector to the Flink ecosystem.
In order to introduce a new connector, we'll first need to go through the FLIP
process. See
https://cwiki.apache.org/confluence/display/FLINK/FLIP-252%3A+Amazon+DynamoDB+Sink+Connector
as an example. For MongoDB, a new FLIP would need to be created, discussed and
voted on. When the vote has passed, we can create a new repository (like
github.com/apache/flink-connector-mongodb) where the source code for that
connector can be stored. New connectors aren't currently being merged in
Flink's main repo.
One question, as I see there's also https://github.com/mongo-flink/mongo-flink
- Are you familiar with that connector?
> Flink MongoDB Connector
> -----------------------
>
> Key: FLINK-6573
> URL: https://issues.apache.org/jira/browse/FLINK-6573
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Common
> Affects Versions: 1.2.0
> Environment: Linux Operating System, Mongo DB
> Reporter: Nagamallikarjuna
> Assignee: ZhuoYu Chen
> Priority: Not a Priority
> Labels: pull-request-available, stale-assigned
> Attachments: image-2021-11-15-14-41-07-514.png
>
> Original Estimate: 672h
> Remaining Estimate: 672h
>
> Hi Community,
> Currently we are using Flink in the current Project. We have huge amount of
> data to process using Flink which resides in Mongo DB. We have a requirement
> of parallel data connectivity in between Flink and Mongo DB for both
> reads/writes. Currently we are planning to create this connector and
> contribute to the Community.
> I will update the further details once I receive your feedback
> Please let us know if you have any concerns.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
