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

标签： group-byapache-kafkacreate-tableksqldb

Answer 1

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

希望这可以帮助，

安迪