赞
踩
写了一个sql文件,kafka发送的数据经过计算存储到oracle中,通过sql-client的命令行一条条的执行sql语句是没有问题的,但是通过文件执行就会出现标题的错误
最终通过排查发现是sql文件中使用tab键打了空格导致报错,把tab键删除或者换成空格就可以了
错误的写法
CREATE TABLE KafkaTable (
`user_id` BIGINT, -- 这里使用了tab键
`item_id` BIGINT,
`behavior` STRING,
`ts` TIMESTAMP(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
'properties.bootstrap.servers' = 'localhost:9092',
'properties.group.id' = 'testGroup',
'scan.startup.mode' = 'earliest-offset',
'format' = 'csv'
)
正确的写法
CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
`ts` TIMESTAMP(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
'properties.bootstrap.servers' = 'localhost:9092',
'properties.group.id' = 'testGroup',
'scan.startup.mode' = 'earliest-offset',
'format' = 'csv'
)
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。