KSQLDB执行CREATE TABLE语句时因函数名称错误报错求助
KSQLDB执行CREATE TABLE语句时因函数名称错误报错求助
嗨,我一眼就发现问题啦!你遇到的错误完全是因为一个小小的拼写失误——你写的OUNT_DISTINCT漏掉了开头的字母C,正确的KSQLDB聚合函数名称应该是COUNT_DISTINCT。
把你的CREATE TABLE语句里的OUNT_DISTINCT改成COUNT_DISTINCT就可以解决这个问题了,修正后的完整语句如下:
CREATE TABLE PERSON_STATS WITH (VALUE_FORMAT='AVRO') AS SELECT PERSON, LATEST_BY_OFFSET(LOCATION) AS LATEST_LOCATION, COUNT(*) AS LOCATION_CHANGES, COUNT_DISTINCT(LOCATION) AS UNIQUE_LOCATIONS FROM MOVEMENTS GROUP BY PERSON EMIT CHANGES;
以后写KSQLDB函数的时候可以多留意拼写,避免这类小失误哦~
备注:内容来源于stack exchange,提问作者Jeff Cook
相关产品推荐
相关产品推荐

