[ 
https://issues.apache.org/jira/browse/FLINK-21660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Kurt Young closed FLINK-21660.
------------------------------
    Resolution: Fixed

fixed: 5b9e7882207357120717966d8bf7efd53c53ede5

> CREATE TABLE LIKE cannot reference tables in HiveCatalog
> --------------------------------------------------------
>
>                 Key: FLINK-21660
>                 URL: https://issues.apache.org/jira/browse/FLINK-21660
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Hive
>    Affects Versions: 1.12.1
>            Reporter: liqiang.liu
>            Assignee: Rui Li
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.13.0
>
>
> create a table like with a hive catalog table
> {color:#cc7832}CREATE TABLE {color}temp_order
> {color:#cc7832}WITH {color}(
>  {color:#6a8759}'properties.group.id' {color}= 
> {color:#6a8759}'test1'{color}{color:#cc7832},
> {color} {color:#6a8759}'properties.bootstrap.servers' {color}= 
> {color:#6a8759}'kafka.address'
> {color})
> {color:#cc7832}LIKE {color}hive.ods.flink_order
> It has a error, log is :
>  
> Exception in thread "main" org.apache.flink.table.api.ValidationException: 
> Unable to create a source for reading table 
> 'default_catalog.default_database.test_taos_customer_agent_cinema'.
> Table options are:
> 'connector'='upsert-kafka'
> 'is_generic'='true'
> 'key.format'='json'
> 'properties.bootstrap.servers'='kafka.address'
> 'properties.group.id'='test1'
> 'topic'='topic1'
> 'value.format'='json'
> ...
> Caused by: org.apache.flink.table.api.ValidationException: Unsupported 
> options found for connector 'upsert-kafka'.
> Unsupported options:
> is_generic
>  
> the ’is_generic‘ option is  added by hive catalog,  but  `kafka` connector  
> does not support this  option.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to