Re: flink-json 函数用法

Mon, 30 Nov 2020 00:20:42 -0800 

Hi：
        那我再看看json相关的信息，然后刚才测试的时候发现这个另一个问题
    select ENCODE('ISO-8859-1', F_sp_withdraw_user_name) from t_sp_user_info 
where F_sp_withdraw_user_name is not null;

     Exception in thread "main" 
org.apache.flink.table.client.SqlClientException: Unexpected exception. This is 
a bug. Please consider filing an issue.
        at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
Caused by: org.apache.flink.table.api.TableException: Unsupported conversion 
from data type 'BINARY(1)' (conversion class: [B) to type information. Only 
data types that originated from type information fully support a reverse 
conversion.
        at 
org.apache.flink.table.types.utils.LegacyTypeInfoDataTypeConverter.toLegacyTypeInfo(LegacyTypeInfoDataTypeConverter.java:259)
   使用flnk-sql的ENCODE 进行转码的时候显示如下问题ENCODE(F_sp_withdraw_user_name，'ISO-8859-1') 
也是一样的
   
 
在 2020/11/30 15:53，“Benchao Li”<libenc...@apache.org> 写入:

    Hi，
    
    目前Flink SQL应该还没有正式支持json函数吧，上面的报错信息看起来也是符合预期的，说的是目前还找不到这个函数。
    
    相关信息可以参考：https://issues.apache.org/jira/browse/FLINK-9477
    
    
    Yan,Yunpeng(DXM,PB) <yanyunp...@duxiaoman.com> 于2020年11月30日周一 下午2:18写道：
    
    > Flink SQL> select JSON_OBJECT('product_type' VALUE product_type)
    > > from income_fee
    > > ;
    > [ERROR] Could not execute SQL statement. Reason:
    > org.apache.calcite.sql.validate.SqlValidatorException: No match found for
    > function signature JSON_OBJECT(<null>, <CHARACTER>, <NUMERIC>)
    >
    > Flink SQL> select JSON_OBJECT('product_type' VALUE product_type)
    > > from sp_income_fee
    > > where enabled = 1
    > > group by id;
    > [ERROR] Could not execute SQL statement. Reason:
    > org.apache.calcite.sql.validate.SqlValidatorException: No match found for
    > function signature JSON_OBJECT(<null>, <CHARACTER>, <NUMERIC>)
    >
    > Flink SQL> select JSON_ARRAYAGG(product_type)
    > > from income_fee
    > > where f_enabled = 1;
    > [ERROR] Could not execute SQL statement. Reason:
    > org.apache.flink.table.api.TableException: Unsupported Function:
    > 'JSON_ARRAYAGG_ABSENT_ON_NULL'
    >
    > 闫云鹏
    > DXM 支付业务部
    > 地址：北京市海淀区西北旺东路度小满金融总部
    > 邮编：100085
    > 手机：13693668213
    > 邮箱：yanyunp...@duxiaoman.com
    >
    > 度小满金融
    > 精于科技 值得信赖
    >
    >
    >
    > 在 2020/11/30 11:05，“caozhen”<caozhen1...@163.com> 写入:
    >
    >     可以把使用方法和 报错信息 发下嘛？
    >
    >
    >
    >
    >     Yan,Yunpeng(DXM,PB) wrote
    >     > Hi:
    >     >   尝试使用flink-sql将聚合结果json展示的时候发现flink是支持JSON_OBJECTAGG， JSON_ARRAY,
    >     > JSON_OBJECT 等这种函数的（使用的默认的blink），
    > 但是总是报错函数的用法不对，有相关资料来介绍这些函数的使用方法的吗？或者示例
    >     >
    >     > 闫云鹏
    >     > DXM 支付业务部
    >     > 地址：北京市海淀区西北旺东路度小满金融总部
    >     > 邮编：100085
    >     > 手机：13693668213
    >     > 邮箱：
    >
    >     > yanyunpeng@
    >
    >     > &lt;mailto:
    >
    >     > yanyunpeng@
    >
    >     > &gt;
    >     >
    >     > 度小满金融
    >     >
    >     > 精于科技 值得信赖
    >
    >
    >
    >
    >
    >     --
    >     Sent from: http://apache-flink.147419.n8.nabble.com/
    >
    >
    
    -- 
    
    Best,
    Benchao Li

回复