[
https://issues.apache.org/jira/browse/FLINK-35616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-35616:
-------------------------------
Summary: Support upsert into sharded collections for
MongoRowDataSerializationSchema (was: Support upsert into sharded collections)
> Support upsert into sharded collections for MongoRowDataSerializationSchema
> ---------------------------------------------------------------------------
>
> Key: FLINK-35616
> URL: https://issues.apache.org/jira/browse/FLINK-35616
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / MongoDB
> Affects Versions: mongodb-1.2.0
> Reporter: Jiabao Sun
> Assignee: Jiabao Sun
> Priority: Major
>
> {panel:}
> For a db.collection.update() operation that includes upsert: true and is on a
> sharded collection, the full sharded key must be included in the filter:
> * For an update operation.
> * For a replace document operation (starting in MongoDB 4.2).
> {panel}
> https://www.mongodb.com/docs/manual/reference/method/db.collection.update/#upsert-on-a-sharded-collection
> We need to allow users to configure the full sharded key field names to
> upsert into the sharded collection.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
