search

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 924 forks source link

flinkStreamsql 保留字和字段冲突 ，反引号无效 #384

Closed hqisog closed 3 years ago

hqisog commented 3 years ago

例如 ，flinkstreamsql 中，源表

CREATE TABLE test2( event_time varchar, id int, open double , close double , high double, low double, trades int, volume int, timestamp varchar, operate_type varchar, UDFTimeToLong(event_time, 8) as xctime, WATERMARK FOR xctime AS withOffset(xctime, 120000) )WITH( XXXXXXXXXX ）

上面这种建源表，sql 解析失败

hqisog commented 3 years ago

上面 显示不对， open ,close 前后都有 反引号

open close 是保留字

open

a49a commented 3 years ago

我们推出了最新的1.12 在FlinkX项目里。应该没有这个问题了。你试下