[FLINK-17183] the 'create table [if not exists]' syntax is not supported

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.10.0
• Fix Version/s: 1.12.0
• Component/s: Connectors / Hive, Table SQL / API
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: muzimusi
• Created: 16/Apr/20 09:09
• Updated: 08/Oct/21 09:48
• Resolved: 20/May/20 08:37

Description

The 'create table [if not exists]' syntax is not supported by FlinkSqlParserImpl. For example, the following example will throw an error:

 

CREATE TABLE IF NOT EXISTS default_catalog.default_database.access_log_hive (
     source_ip VARCHAR,
     target_ip VARCHAR,
     behavior VARCHAR,
     comm VARCHAR,
     ts TIMESTAMP(3)
 ) WITH (
     'key' = 'value',
      ...
 )

The error message is like this：

Caused by: org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "NOT" at line 1, column 17.
 Was expecting one of:
 {{ <EOF> }}
 {{ "WITH" ...}}
 {{ "COMMENT" ...}}
 {{ "PARTITIONED" ...}}
 {{ "(" ...}}
 {{ "." ...}}

 

 

 

 

Issue Links

• links to: [FLINK-17183][table] support 'create table [if not exists]' syntax
• links to: Flink SQL DDL design doc
• links to: GitHub Pull Request #11772