KSQL allows persistent queries containing limits to be created.

[big-andy-coates]

I was playing around with the clickstream demo and a cut & paste error saw me running this statement:

CREATE STREAM CS2 AS select _time, _time + 1000 as time2 from clickstream limit 5;

This query executed without error. Then running this:

select * from CS2;

saw a constant stream of rows.

So to my mind, either KSQL should have rejected the LIMIT clause in the CSAS statement, or should have limited the output to 5 rows per partition.

[agavra]

Reproduced this on master as of c0bfa41a1095