Hi, I've submitted a pull request for JIRA ticket FLINK-37950 <https://issues.apache.org/jira/browse/FLINK-37950> supporting performance enhancement for bulkwrite via optional configuration parameters.
1. Unordered writes: https://mongodb.github.io/mongo-java-driver/5.6/apidocs/driver-core/com/mongodb/client/model/BulkWriteOptions.html#ordered(boolean) <https://github.com/apache/flink-connector-mongodb/pull/url> 2. Bypass document validation : https://mongodb.github.io/mongo-java-driver/5.6/apidocs/driver-core/com/mongodb/client/model/BulkWriteOptions.html#bypassDocumentValidation(java.lang.Boolean) <https://github.com/apache/flink-connector-mongodb/pull/url> This is a backward compatible change with existing behaviour of ordered writes with document validation, is maintained using configuration default values. Pull request: [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. by neoneo008 · Pull Request #58 · apache/flink-connector-mongodb <https://github.com/apache/flink-connector-mongodb/pull/58> Can someone please help review? Regards, Rahul Teke
