游客lkx6h3pxq6jya_个人页

我不创建分区表可以创建成功但是查询会报错 Flink SQL> create table hudi_flink_test1 ( uuid varchar(20) ,name varchar(10) ,age int ,ts timestamp(3)) with ( 'connector' = 'hudi' ,'path' = 'hdfs://hadoop102:8020/user/hhive/warehouse/hudi_flink/hudi_flink_test1' );[INFO] Table has been created. Flink SQL> desc hudi_flink_test1;[ERROR] Unknown or invalid SQL statement. Flink SQL> select * from hudi_flink_test1;[ERROR] Could not execute SQL statement. Reason:org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' inthe classpath. Reason: Required context properties mismatch. The following properties are requested:connector=hudipath=hdfs://hadoop102:8020/user/hhive/warehouse/hudi_flink/hudi_flink_test1schema.0.data-type=VARCHAR(20)schema.0.name=uuidschema.1.data-type=VARCHAR(10)schema.1.name=nameschema.2.data-type=INTschema.2.name=ageschema.3.data-type=TIMESTAMP(3)schema.3.name=ts The following factories have been considered:org.apache.flink.table.sources.CsvBatchTableSourceFactoryorg.apache.flink.table.sources.CsvAppendTableSourceFactory