имя является нулевой ошибкой при выполнении групп по имени столбца в слиянии Кафки

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;

имя равно нулю

имя ошибки равно нулю

после того, какполе структуры в схеме.работает простой запрос на выборку без группировки по.

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;