[FLINK-35616] Support upsert into sharded collections for MongoRowDataSerializationSchema

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Affects Version/s: mongodb-1.2.0
• Fix Version/s: mongodb-1.3.0
• Component/s: Connectors / MongoDB
• Labels: pull-request-available
• Assignee: Jiabao Sun
• Reporter: Jiabao Sun
• Created: 14/Jun/24 10:15
• Updated: 16/Jul/24 01:58
• Resolved: 16/Jul/24 01:58

Description

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).

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.

Issue Links

• links to: GitHub Pull Request #37