Я хочу использовать Kinesis Data Analytics (или какой-либо другой управляемый сервис AWS) для пакетной обработки записей на основе критериев фильтрации. Идея заключалась в том, чтобы по мере поступления записей мы запускали окно сеанса и собирали все...

В первую очередь: Я как бы новичок в Flink (понимаю принцип и могу создать любую базовую потоковую работу, которая мне нужна) Я использую Kinesis Analytics для запуска своего задания Flink, и по умолчанию он использует инкрементную контрольную...

Я использую семантику времени событий в своем приложении Flink (версия 1.11.1), которое работает в AWS - kinesis analytics. Это приложение имеет источник как поток кинезиса и приемник как Postgres. Интервал контрольной точки составляет 10 секунд,...

У нас есть приложение Apache Flink POC, которое отлично работает локально, но после развертывания в Kinesis Data Analytics (KDA) оно не отправляет записи в приемник. Используемые технологии Местный Source: Kafka 2.7 1 broker 1 тема с...