lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2698] Remove the table source options validation (#3940)

Browse Source 
Co-authored-by: yuzhaojing <yuzhaojing@bytedance.com>
This commit is contained in:
yuzhaojing
2021-11-08 16:56:03 +08:00
committed by GitHub
parent c7bf2c7687
commit 7aaf47e716
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java
View File

@@ -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.connector.source.DynamicTableSource;
import org.apache.flink.table.factories.DynamicTableSinkFactory; import org.apache.flink.table.factories.DynamicTableSinkFactory;
import org.apache.flink.table.factories.DynamicTableSourceFactory; 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.DataType;
import org.apache.flink.table.types.logical.LogicalType; import org.apache.flink.table.types.logical.LogicalType;
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
@@ -62,10 +61,7 @@ public class HoodieTableFactory implements DynamicTableSourceFactory, DynamicTab
@Override @Override
public DynamicTableSource createDynamicTableSource(Context context) { public DynamicTableSource createDynamicTableSource(Context context) {
FactoryUtil.TableFactoryHelper helper = FactoryUtil.createTableFactoryHelper(this, context); Configuration conf = FlinkOptions.fromMap(context.getCatalogTable().getOptions());
helper.validate();
Configuration conf = (Configuration) helper.getOptions();
ResolvedSchema schema = context.getCatalogTable().getResolvedSchema(); ResolvedSchema schema = context.getCatalogTable().getResolvedSchema();
sanityCheck(conf, schema); sanityCheck(conf, schema);
setupConfOptions(conf, context.getObjectIdentifier().getObjectName(), context.getCatalogTable(), schema); setupConfOptions(conf, context.getObjectIdentifier().getObjectName(), context.getCatalogTable(), schema);