游客lkx6h3pxq6jya
游客lkx6h3pxq6jya_个人页
游客lkx6h3pxq6jya
文章
0
问答
2
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
2024年10月
-
10.20 21:10:43
回答了问题
2024-10-20 21:10:43
sql client不能创建表: 那位大佬给看看这是怎么回事
赞221 踩0 评论0 -
10.20 20:53:46
提交了问题
2024-10-20 20:53:46
暂无更多信息
-
提交了问题
2024-10-20
sql client不能创建表: 那位大佬给看看这是怎么回事
-
回答了问题
2024-10-20
sql client不能创建表: 那位大佬给看看这是怎么回事
我不创建分区表可以创建成功但是查询会报错 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赞221 踩0 评论0
滑动查看更多
暂无更多信息