例如我们想和kafka连接时WITH需要添加
'connector’这项,如果是连接hive的除了需要添加该项之外还需要添加连接hiv所需的JDBC的依赖。
当缺少这两项时可能会报这种错误。
String sql="CREATE TABLE Orders (`business_time` STRING, `prod_name` STRING, `product_type` STRING,`vol` Double,`batch_time` TIMESTAMP) WITH ( 'connector' = 'filesystem','path' = 'D:\杂文件/sql.txt','format' = 'json')";
解决方式:再见表语句中添加该配置,如果是需要连接数据库的话,添加该项配置并添加JDBC的依赖。
我在出现该问题时的报错是:Table options do not contain an option key ‘format’ for discovering a connector.
后来发现是缺少了’format’这项,添加上之后就报了别的错了。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)