From 7aaf47e716a303b5fea5150a5093a849f60ff607 Mon Sep 17 00:00:00 2001 From: yuzhaojing <32435329+yuzhaojing@users.noreply.github.com> Date: Mon, 8 Nov 2021 16:56:03 +0800 Subject: [PATCH] [HUDI-2698] Remove the table source options validation (#3940) Co-authored-by: yuzhaojing --- .../main/java/org/apache/hudi/table/HoodieTableFactory.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java b/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java index 40801ad39..5299551fc 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java +++ b/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java @@ -40,7 +40,6 @@ import org.apache.flink.table.connector.sink.DynamicTableSink; import org.apache.flink.table.connector.source.DynamicTableSource; import org.apache.flink.table.factories.DynamicTableSinkFactory; import org.apache.flink.table.factories.DynamicTableSourceFactory; -import org.apache.flink.table.factories.FactoryUtil; import org.apache.flink.table.types.DataType; import org.apache.flink.table.types.logical.LogicalType; import org.apache.hadoop.fs.Path; @@ -62,10 +61,7 @@ public class HoodieTableFactory implements DynamicTableSourceFactory, DynamicTab @Override public DynamicTableSource createDynamicTableSource(Context context) { - FactoryUtil.TableFactoryHelper helper = FactoryUtil.createTableFactoryHelper(this, context); - helper.validate(); - - Configuration conf = (Configuration) helper.getOptions(); + Configuration conf = FlinkOptions.fromMap(context.getCatalogTable().getOptions()); ResolvedSchema schema = context.getCatalogTable().getResolvedSchema(); sanityCheck(conf, schema); setupConfOptions(conf, context.getObjectIdentifier().getObjectName(), context.getCatalogTable(), schema);