flink 1.12.2 sql-cli 写入Hive报错 is_generic

Thu, 01 Apr 2021 01:08:58 -0700 

当配置好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/

回复