group-by - 在confluent kafka ksql中按column_name进行分组时名称为空错误

Question

我在 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 是架构中的结构字段。没有分组依据的简单选择查询工作正常。

Answer 1

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

希望这可以帮助，

安迪

Answer 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;