Flink SQL create table 关键字 table 加反引号 解析失败

Sun, 07 Jun 2020 00:33:12 -0700 

各位大佬，

我的数据源 json 里有 database, table 字段，想解析出来，是保留关键字，我加了反引号，但是还是报错，这是为什么呢

    val bsSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
    val bsTableEnv = StreamTableEnvironment.create(env, bsSettings)
    val sourceTable = """CREATE TABLE my_kafak_source (
                        |    `table` varchar,
                        |    `database` varchar,
                        |    `data` row < transaction_id varchar,
                        |               user_id int,
                        |               amount int,
                        |    >,
                        |    maxwell_ts bigint,
                        |    ts_watermark as
TO_TIMESTAMP(FROM_UNIXTIME(maxwell_ts/1000))
                        |) WITH (
                        |)""".stripMargin

error

 The program finished with the following exception:

org.apache.flink.client.program.ProgramInvocationException: The main
method caused an error: SQL parse failed. Encountered "table" at line
1, column 8.
Was expecting one of:
    "ABS" ...
    "ALL" ...
    "ARRAY" ...
    "AVG" ...
    "CARDINALITY" ...
    "CASE" ...
    "CAST" ...
    "CEIL" ...

回复