Образец Apache Spark Kinesis не работает

Отчет о применении для application_ (состояние: ПРИНЯТО) никогда не заканчивается для Spark Submit (с Spark 1.2.0 на YARN)

Ожидаемое поведение для AWS Kinesis ShardIteratorType TRIM_HORIZON

контекстЯ не обязательно имею в виду приложение на основе KCL, просто вызовы чистого API Kinesis.Использует ли

Какова задержка данных потокового журнала между облачными сервисами AWS и Google?

Кто-нибудь имел опыт работы с:Отправка потоковых / микропакетированных данных журнала из Amazon в BigQuery для обработки и может пролить свет на любую пробле...

несколько потребителей на осколок кинезиса

Я читал, у вас может быть несколько потребительских приложений для каждого потока кинезиса.http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers...

Проблемы с надежностью Checkpointing / WAL в Spark Streaming 1.6.0

ОписаниеУ нас есть приложение Spark Streaming 1.5.2 в Scala, которое считывает события JSON из потока Kinesis, выполняет некоторые преобразования / агрегации...

put_records () принимает только ключевые аргументы в Kinesis boto3 Python API

Вызовите REST API для Amazon Kinesis с настройкой API Gateway

Я пытаюсь отправить HTTP-запрос на отправку записи в Amazon Kinesis Stream. Есть несколько способов (Kinesis Client, KPL, настройка AWS Gateway в качестве Ki...

Как разветвлять поток кинесиса AWS?

Погуглив «Checkpoint Kinesis», я дал ответы на мои вопросы.