Resultados de la búsqueda a petición "amazon-kinesis"

2 la respuesta

Comportamiento esperado para AWS Kinesis ShardIteratorType TRIM_HORIZON

Contexto: No me refiero necesariamente a una aplicación basada en KCL, solo a llamadas de API Kinesis puras. ¿Usando elTRIM_HORIZON el tipo de iterador de fragmentos le proporciona de inmediato el registro publicado más temprano en la secuencia ...

12 la respuesta

El informe de aplicación para application_ (estado: ACEPTADO) nunca termina para Spark Submit (con Spark 1.2.0 en YARN)

Estoy ejecutando la aplicación kinesis plus spark https://spark.apache.org/docs/1.2.0/streaming-kinesis-integration.html [https://spark.apache.org/docs/1.2.0/streaming-kinesis-integration.html] Estoy corriendo como abajo comando en la instancia ...

2 la respuesta

Apache Spark Kinesis Sample no funciona

Estoy tratando de ejecutar elJavaKinesisWordCountASL [https://github.com/apache/spark/blob/master/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java] ejemplo. El ejemplo parece conectarse a mi ...