AWS Kinesis Analytics, как сделать простой запрос агрегации? - PullRequest
0 голосов
/ 12 февраля 2019

Настоящий запрос

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (failedCount INTEGER);
CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
SELECT STREAM COUNT("fxStatus") as failedCount
FROM "SOURCE_SQL_STREAM_001"
GROUP BY "fxStatus" WHERE "fxStatus" SIMILAR TO 'FAILED' ;

Ошибка

Невозможно агрегировать бесконечный поток: предложение GROUP BY не указано или не содержит монотонных выражений.

Что я делаю не так?

...