我使用的是从curl post发布到ksql的kafka restapi，如果我不使用limit20，它将挂起。如果我再次使用它来查询表，它也会挂起。我在python脚本中运行这个，我在rowtime bcoz之间查询，我无法从流中获得最新结果，因为它是连续的和持久的。
data = {"ksql":"SELECT MAX(ROWTIME),TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss'),MYFIRMWAREVERSION,MYBASEMACID,BOOTTS,IMEI,PRODDEVICESERIALNUM,RESETREASON FROM NOV_STREAM WHERE TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss') >= '2018-12-11 00:29:30'AND TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss') <= '2018-12-11 23:29:30' GROUP BY ROWTIME,MYFIRMWAREVERSION,MYBASEMACID,BOOTTS,IMEI,PRODDEVICESERIALNUM,RESETREASON LIMIT 20;","streamsProperties":{"ksql.streams.auto.offset.reset": "earliest","format": "json"}}
1条答案
按热度按时间mtb9vblg1#
这是意料之中的。ksql查询，除非使用
LIMIT，是一个连续流式查询。也就是说，根据设计，它不会自行终止。流和表都是这种情况。对于表，查询将继续运行，并将在其查询输出中显示对表的任何后续更新。