Jiabao Sun created FLINK-41483:
----------------------------------
Summary: MongoDB Connector does not propagate ordered-writes and
bypass-document-validation table options
Key: FLINK-41483
URL: https://issues.apache.org/jira/browse/FLINK-41483
Project: Flink
Issue Type: Bug
Components: Connectors / MongoDB
Reporter: Jiabao Sun
While reviewing the changes introduced in
[https://github.com/apache/flink-connector-mongodb/pull/58], I noticed that the
two newly added configuration options, sink.ordered-writes and
sink.bypass-document-validation, are not properly propagated through the
Table/SQL Sink implementation.
Specifically:
* MongoDynamicTableFactory.optionalOptions() does not register these two
options, so explicitly configuring them in a SQL DDL may fail validation.
* MongoConfiguration does not expose getters for these options.
* MongoDynamicTableFactory.getWriteOptions() does not propagate them into
MongoWriteOptions.
* MongoDynamicTableSink.getSinkRuntimeProvider() does not pass them to
MongoSink.builder().
As a result, although these options are documented for the Table/SQL connector,
they cannot currently take effect through that API.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
