[jira] [Created] (FLINK-39334) flink-connector-mongodb fails when write concern is set to zero

["Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org>]

Jacob Jona Fahlenkamp created FLINK-39334:
---------------------------------------------

             Summary: flink-connector-mongodb fails when write concern is set to zero
                 Key: FLINK-39334
                 URL: https://issues.apache.org/jira/browse/FLINK-39334
             Project: Flink
          Issue Type: Bug
          Components: Connectors / MongoDB
    Affects Versions: 1.20.3
            Reporter: Jacob Jona Fahlenkamp


When specifying write concern zero, the mongo sink fails. This is because [it always sets the bypassDocumentValidation option.|https://github.com/apache/flink-connector-mongodb/blob/main/flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java#L221]. But if the write concern is set to zero this is not allowed by the mongo driver. The fix would be to set the bypassDocumentValidation option only if it's true.

Reproduction:
{code:java}
@Container
private static final MongoDBContainer MONGO_CONTAINER =
        MongoTestUtil.createMongoDBContainer();

@Test
void writeConcernZero() throws Exception {
    MongoSink<BsonDocument> sink = MongoSink.<BsonDocument>builder()
            .setUri(MONGO_CONTAINER.getConnectionString() + "/?w=0")
            .setDatabase("database")
            .setCollection("collection")
            .setSerializationSchema((doc, context) -> new InsertOneModel<>(doc))
            .build();
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    env.fromData(new BsonDocument("hello", new BsonString("world")))
            .sinkTo(sink);
    env.execute();
} {code}
this throws:
{code:java}
com.mongodb.MongoClientException: Specifying bypassDocumentValidation with an unacknowledged WriteConcern is not supported{code}
 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)