Re: flink-json 函数用法

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

Re: flink-json 函数用法

Hi， 目前Flink SQL应该还没有正式支持json函数吧，上面的报错信息看起来也是符合预期的，说的是目前还找不到这个函数。 相关信息可以参考：https://issues.apache.org/jira/browse/FLINK-9477 Yan,Yunpeng(DXM,PB) 于2020年11月30日周一 下午2:18写道： > Flink SQL> select JSON_OBJECT('product_type' VALUE product_type) > > from income_fee > > ; > [ERROR] Could not execute SQL

Re: flink-json 函数用法

提示没法送成功，重发测试 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(, , ) Flink SQL> select

Re: flink-json 函数用法

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(, , ) Flink SQL> select JSON_OBJECT('product_type' VALUE

Re: flink-json 函数用法

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(, , ) Flink SQL> select JSON_OBJECT('product_type'

flink-json 函数用法

Hi: 尝试使用flink-sql将聚合结果json展示的时候发现flink是支持JSON_OBJECTAGG， JSON_ARRAY, JSON_OBJECT 等这种函数的（使用的默认的blink）， 但是总是报错函数的用法不对，有相关资料来介绍这些函数的使用方法的吗？或者示例 闫云鹏 DXM 支付业务部 地址：北京市海淀区西北旺东路度小满金融总部 邮编：100085 手机：13693668213 邮箱：yanyunp...@duxiaoman.com 度小满金融 精于科技 值得信赖