Mans Singh created FLINK-23549:
----------------------------------

             Summary: Kafka table connector create table example in docs has 
syntax error
                 Key: FLINK-23549
                 URL: https://issues.apache.org/jira/browse/FLINK-23549
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka, Documentation
    Affects Versions: 1.13.1
            Reporter: Mans Singh
             Fix For: 1.14.0


The create table example in the docs has an syntax error (extra comma after the 
opening bracket):
{quote}CREATE TABLE KafkaTable (,
 `ts` TIMESTAMP(3) METADATA FROM 'timestamp',
 `user_id` BIGINT,
 `item_id` BIGINT,
 `behavior` STRING
 ) WITH (
 'connector' = 'kafka',
 ...
 )
{quote}
On executing in the FlinkSQL it produces an error:
{quote}[ERROR] Could not execute SQL statement. Reason:
 org.apache.flink.sql.parser.impl.ParseException: Encountered "," at line 1, 
column 26.
{quote}



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

Reply via email to