你好， 我用你提供的这个DDL没有复现这个问题，有更详细的操作步骤么？另外如果kafka表是通过create table like创建的话有个已知问题： https://issues.apache.org/jira/browse/FLINK-21660
On Thu, Apr 1, 2021 at 4:08 PM HunterXHunter <[email protected]> wrote: > 当配置好HiveCatalog后， > SQL-Cli 也可以查到hive库表信息 > 创建kafka表： > > create table test.test_kafka( > word VARCHAR > ) WITH ( > 'connector' = 'kafka', > 'topic' = 'xx', > 'scan.startup.mode' = 'latest-offset', > 'properties.bootstrap.servers' = 'xx', > 'properties.group.id' = 'test', > 'format' = 'json', > 'json.ignore-parse-errors' = 'true' > ); > 在 Hive里面可以查到改表 > hive > DESCRIBE FORMATTED test_kafka > ........... > is_generic true > ......... > > 但是我在 Flink SQL > select * from test.test_kafka; > 报错： > org.apache.flink.table.api.ValidationException: Unsupported options found > for connector 'kafka'. > Unsupported options: > is_generic > Supported options: > connector > format > json.fail-on-missing-field > json.ignore-parse-errors > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ > -- Best regards! Rui Li
