在 ksqldb 中翻滚 windows 不支持保留期吗？

Question

我似乎无法弄清楚为什么我的 create table 语句失败了：

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

我已经看过 grammar，但看起来应该可以。

删除 RETENTION 部分使其工作，所以它无法解析。

这是 5.5 版本（在 ksql 命令行中输入的版本），所以是最新的。

Answer 1

Confluent Platform v5.5 附带的 ksqlDB 版本不支持 RETENTION 语法。见5.5 grammer。

看起来这是在 ksqlDB 0.8 版本中引入的。即将发布的 Confluent Platform v6.0.0 版本将随 ksqlDB 0.10 一起发布，并将支持 RETENTION 语法。

如果您需要 RETENTION，请等待 CP 6.0.0 或使用 ksqlDB v0.8 或更高版本的社区版本之一。

在 ksqldb 中翻滚 windows 不支持保留期吗？

Is retention period not supported for tumbling windows in ksqldb?

ksqldb