在confluent kafka ksql中按column_name进行分组时名称为空错误答案

【问题标题】：name is null error while doing group by column_name in confluent kafka ksql在confluent kafka ksql中按column_name进行分组时名称为空错误
【发布时间】：2020-05-14 00:19:51
【问题描述】：

我在 confluent-5.0.0 中遇到错误。

ksql>CREATE TABLE order_per_hour AS SELECT after->order_id,count(*) FROM transaction WINDOW SESSION(60 seconds) GROUP BY after->order_id;

名称为空

错误名称为空

after 是架构中的结构字段。没有分组依据的简单选择查询工作正常。

【问题讨论】：

标签： group-by apache-kafka create-table ksqldb

【解决方案1】：

我已经提交了一个 PR 来为 KSQL 添加对此的支持https://github.com/confluentinc/ksql/pull/2076

希望这会有所帮助，

安迪

【讨论】：

【解决方案2】：

目前您只能在GROUP BY 子句中使用列名。作为一种变通方法，您可以将查询编写如下：

CREATE STREAM foo AS SELECT after->order_id as o_id FROM transaction;
CREATE TABLE order_per_hour AS SELECT o_id,count(*) FROM foo WINDOW SESSION(60 seconds) GROUP BY o_id;

【讨论】：