From e867c75580d4abac54ead5b2efa07f0a6a418698 Mon Sep 17 00:00:00 2001 From: Jiabao Sun Date: Fri, 10 Sep 2021 08:38:10 -0500 Subject: [PATCH] [mongodb] Remove no need config option prefix 'debezium.' (#420) --- .../connectors/mongodb/table/MongoDBTableSourceFactory.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java b/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java index babd51bf8..738e05b5e 100644 --- a/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java +++ b/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java @@ -29,8 +29,6 @@ import org.apache.flink.table.factories.DynamicTableSourceFactory; import org.apache.flink.table.factories.FactoryUtil; import org.apache.flink.table.utils.TableSchemaUtils; -import com.ververica.cdc.debezium.table.DebeziumOptions; - import java.time.ZoneId; import java.util.HashSet; import java.util.Set; @@ -177,7 +175,7 @@ public class MongoDBTableSourceFactory implements DynamicTableSourceFactory { public DynamicTableSource createDynamicTableSource(Context context) { final FactoryUtil.TableFactoryHelper helper = FactoryUtil.createTableFactoryHelper(this, context); - helper.validateExcept(DebeziumOptions.DEBEZIUM_OPTIONS_PREFIX); + helper.validate(); final ReadableConfig config = helper.getOptions();