你好:我按照上述方法进行测试,往es插入数据的时候一直报这个问题,是哪里有问题么?
create view uu AS select collect(userBankTime) as userBank ,name from ( select name, row(name,description) as userBankTime from tt_haha) group by name; // 创建视图,描述userBank类型是MULTITYPE Flink SQL> desc uu; root |-- userBank: MULTISET<ROW<`EXPR$0` STRING, `EXPR$1` STRING> NOT NULL> NOT NULL |-- name: STRING CREATE TABLE user_log_sink_10 ( > name STRING, > maps MULTISET<ROW<name STRING,description STRING>>, > PRIMARY KEY (name) NOT ENFORCED > ) WITH ( > 'connector' = 'elasticsearch-6', > 'hosts' = 'xxxx', > 'index' = 'enriched_orders', > 'document-type' = 'user' > ); insert into user_log_sink_10 select name, collect(userBankTime) as maps from (select name, row(name,description) as userBankTime from tt_haha) group by name; [INFO] Submitting SQL update statement to the cluster... [ERROR] Could not execute SQL statement. Reason: java.lang.ClassCastException: org.apache.flink.table.types.logical.MultisetType cannot be cast to org.apache.flink.table.types.logical.MapType 还有select name, collect(userBankTime) as maps from (select name, row(name,description) as userBankTime from tt_haha) group by name 出来的结果是 test123 {test123,123123=1} 123123 {123123,ff=1, 123123,kk=2} 这种的,在flink sql中是什么格式呢? |--------------------| 在 2020/9/21 下午3:05,“Jark Wu”<imj...@gmail.com> 写入: 1. concat 是内置函数,可以直接用。 2. 内置函数中没有 group_concat,不过有个类似功能的 listagg 3. 内置函数,不需要额外引入包,可以直接使用。内置函数列表请查看官方文档 [1] 4. 没有所谓的 flink sql cdc client, 只有 flink sql client,cdc 是其支持的一个功能。 5. 不清楚你说的只支持部分 sql 操作是指哪些 sql 操作不支持? 具体支持的 sql 操作,请查看官网[2]. Best, Jark [1]: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/functions/systemFunctions.html [2]: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/queries.html On Mon, 21 Sep 2020 at 14:59, Li,Qian(DXM,PB) <liq...@duxiaoman.com> wrote: > Fink sql cdc client 好多sql函数都不支持呀,比如CONCAT(a,b,c) 或者 GROUP_CONCAT(a,b) > > 是我还需要引入什么包么?如果支持的话,上面说的这种格式就可以用GROUP_CONCAT 很好的解决了, > > 另外Fink sql cdc client只支持部分sql操作么?具体支持那些函数,有相关的官方文档么? > > > 在 2020/9/21 下午1:42,“Jark Wu”<imj...@gmail.com> 写入: > > 你可以通过 groupby collect 来将一对多的关系聚合起来,代码类似如下: > > select userId, collect(userBankTime) > from ( > select userId, concat(userBankNo, '_', createTime) as userBankTime > from aa as a left join bb as b where a.userId=b.userId > ) group by userId; > > > Best, > Jark > > On Mon, 21 Sep 2020 at 12:20, Li,Qian(DXM,PB) <liq...@duxiaoman.com> > wrote: > > > 请问: > > > > 我在使用Flink CDC SQL CLI的时候,想将关联的两张表的一对多关系 > > 映射成ARRAY[ROW(userBankNo,createTime)]的形式,要怎么映射呢? > > 表aa > > id, userId > > 表 bb > > userId,userBankNo,createTime > > > > select * from aa as a left join bb as b where a.userId=b.userId > > > > 谢谢! > > > > > > >