FlinkSQL 1.10.0 where条件包含关键字列名的过滤条件不能使用=判断

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

FlinkSQL 1.10.0 where条件包含关键字列名的过滤条件不能使用=判断

LiangbinZhang

测试代码如下:

create view sink_test as
select
    id
    ,type
    ,student_id
    ,kefu_id
    ,action_time
    ,action_user
    ,distribute_status
    ,unbind_type
    ,`comment`
    ,time_created
    ,pull_from
from distribute_new_log
where `comment` ='娃娃鱼';

print table sink_test;

当使用关键字列做过滤条件时,能过滤出符合的数据,但是关键字列comment的值输出为unicode码(\u5B9A\u5411\u5206\u914DTMK\u5C0F\u7EC4),并不是中文。正常来说SQL中字符串判断用=是支持的吧。测试下来发现使用`comment`
like '娃娃鱼',输出就没问题,写如结果表数据显示正常,不知道这是不是10版本的sql限制?



--
Sent from: http://apache-flink.147419.n8.nabble.com/