Re: flink-json 函数用法

3，“Benchao Li” 写入: 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' VA

Re: flink-json 函数用法

ncome_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' 在 2020/11/30 11:05，“caozhen” 写入: 可以把使用方法和 报错信息 发下嘛？ Yan,Yunpeng(DXM,PB) wrote > Hi:

Re: flink-json 函数用法

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' 在 2020/11/30 11:05，“caozhen” 写入: 可以把使用方法和 报错信息 发下嘛？ Yan,Yunpeng(DXM,PB) wrote > Hi: >

Re: flink-json 函数用法

uxiaoman.com 度小满金融 精于科技 值得信赖 在 2020/11/30 11:05，“caozhen” 写入: 可以把使用方法和 报错信息 发下嘛？ Yan,Yunpeng(DXM,PB) wrote > Hi: > 尝试使用flink-sql将聚合结果json展示的时候发现flink是支持JSON_OBJECTAGG， JSON_ARRAY, > JSON_OBJECT 等这种函数的（使用的默认的blink）， 但是总是报错函数的用法不对，有相关资料来介绍这些函数的使用方法

flink-json 函数用法

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

Re: [DKIM Failure] Re: 【闫云鹏】Flink sql 写入es实现object嵌套形式

Hi: 那使用sql怎么表示了？ 查询的结果怎么放入 arrya>中 我刚才尝试使用GROUP_CONCAT来实现sql的拼接，但是flinksql不支持 闫云鹏 在 2020/9/2 16:51，“Danny Chan” 写入: [ { f:f },{ g:g } ] 可否用 Array> 来表达？ Best, Danny Chan 在 2020年9月2日 +0800 PM3:54，user-zh@flink.apache.org，写道：

【闫云鹏】Flink sql 写入es实现object嵌套形式

Hi 我使用flink sql mysql作为原表，多表join后将结果写入es的时候如何实现这种Object结构 { a:a, b:{ c:c d:d }, e:[ { f:f },{ g:g } ] } 看到了sql中支持的数据类型是有map 或者 row这种来支持的，但是测试了几次都没成功，能给个实例？ 闫云鹏

Re: 【闫云鹏】Flink cdc 连接mysql5.7.25报错

Hi Flink 版本 1.11.1 直接使用的cdc的包订阅bin-log public static void main(String[] args) throws Exception { SourceFunction sourceFunction = MySQLSource.builder() .hostname("") .port(***) .databaseList(" ") // monitor all tables under

Re: 【闫云鹏】Flink cdc 连接mysql5.7.25报错

有大佬帮忙看看？ 闫云鹏 DXM 支付业务部 地址：北京市海淀区西北旺东路度小满金融总部 邮编：100085 手机：13693668213 邮箱：yanyunp...@duxiaoman.com<mailto:yanyunp...@duxiaoman.com> 度小满金融 精于科技 值得信赖 发件人: "Yan,Yunpeng(DXM,PB)" 答复: "user-zh@flink.apache.org" 日期: 2020年8月26日 星期三 11:24 收件人: "user-zh@flink.apache.

【闫云鹏】Flink cdc 连接mysql5.7.25报错

Hi all: 使用flink cdc连接mysql 5.7.25 使用默认的8.0.16的mysql驱动报错如下信息 Caused by: java.sql.SQLNonTransientConnectionException: CLIENT_PLUGIN_AUTH is required at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110) at