Не поддерживается ли срок хранения для tumbling windows в ksqldb? - PullRequest
Новая
       30

Не поддерживается ли срок хранения для tumbling windows в ksqldb?

1 голос
/ 19 июня 2020

Кажется, я не могу понять, почему мой оператор создания таблицы не работает: 

ksql> create table rst_wind_2 as select id, avg(intensity), min(rowtime) as `from` from rst2 WINDOW TUMBLING (SIZE 5 SECONDS, RETENTION 7 DAYS) group by id emit changes;
line 1:119: mismatched input ',' expecting ')'
Statement: create table rst_wind_2 as select id, avg(intensity), min(rowtime) as `from` from rst2 WINDOW TUMBLING (SIZE 5 SECONDS, RETENTION 7 DAYS) group by id emit changes;
Caused by: line 1:119: mismatched input ',' expecting ')'
Caused by: org.antlr.v4.runtime.InputMismatchException

Я пошел и посмотрел на грамматику , но похоже, что это должен работать.

Удаление части RETENTION заставляет его работать, поэтому почему-то он просто не может анализировать.

Это версия 5.5 (типизированная версия в командной строке k sql), поэтому самый последний.

1 Ответ

0 голосов
/ 19 июня 2020

Версия ksqlDB, поставляемая с Confluent Platform v5.5, не поддерживает синтаксис RETENTION. См. 5,5 грамма .

Похоже, это было введено в ksqlDB версии 0.8. Предстоящий выпуск Confluent Platform, v6.0.0, будет поставляться с ksqlDB 0.10 и будет поддерживать синтаксис RETENTION.

Если вам требуется RETENTION, дождитесь выхода CP 6.0.0 или используйте один из выпусков сообщества ksqlDB v0. 8 или новее.

...