Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-23549

Kafka table connector create table example in docs has syntax error

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      The create table example in the docs has an syntax error (extra comma after the opening bracket):

      CREATE TABLE KafkaTable (,
      `ts` TIMESTAMP(3) METADATA FROM 'timestamp',
      `user_id` BIGINT,
      `item_id` BIGINT,
      `behavior` STRING
      ) WITH (
      'connector' = 'kafka',
      ...
      )

      On executing in the FlinkSQL it produces an error:

      [ERROR] Could not execute SQL statement. Reason:
      org.apache.flink.sql.parser.impl.ParseException: Encountered "," at line 1, column 26.

        Attachments

          Activity

            People

            • Assignee:
              mans2singh Mans Singh
              Reporter:
              mans2singh Mans Singh

              Dates

              • Created:
                Updated:

                Time Tracking

                Estimated:
                Original Estimate - 0.25h
                0.25h
                Remaining:
                Remaining Estimate - 0.25h
                0.25h
                Logged:
                Time Spent - Not Specified
                Not Specified

                  Issue deployment