spark-rabbitmq

spark-rabbitmq copied to clipboard

Add possibility to specify SSL protocol

7

Fixes #107

jniebuhr

java.lang.VerifyError: Inconsistent stackmap frames at branch target 152

3

Environment - Scala 2.11.8, spark 2.1.0 (with spark-core_2.11, spark-streaming_2.11), spark-rabbitmq 0.5.1. When I run my Spark Streaming job using spark-submit on my standalone spark instance , I get below error...

alankala

RabbitMQ Receiver fails with exception

2

We are running spark application, which receives data form rabbitmq as stream. We are observing below issue after 8 hours (duration is not constant, some time after 24 hours also)....

HardikkumarSoni

Streaming does not stop

2

This is my configuration: StreamingContext streamingContext = new StreamingContext(sparkcontext, Durations.seconds(60000)); But the streaming doesn't seem to be stopping. I keep getting messages and is never able to move ahead

tanroopdhillon

Missing data

4

Hello, i use this rabbitmq receivers but i have some problems. I used a java project ( spring-amqp ) for publish somes Avro messages in RabbitMq and consume it with...

flo076