Stratio spark-rabbitmq issues

Stratio / spark-rabbitmq

RabbitMQ Spark Streaming receiver

Apache License 2.0

208 stars 84 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Fix Compatibility Problems with Spark 3

#136 skyairmj opened 10 months ago
0
BlockRDD[14] at command122480944 while reading the data in Spark Scala [Databricks]

#135 vinayt704 opened 2 years ago
0
Class not found: org.apache.spark.Logging (due to mismatch in spark version?)

#134 JB-data opened 4 years ago
0
Fix rabbitmq close issue, add automatic recovery

#133 core2048 opened 4 years ago
0
java.net.ConnectException: Connection refused: connect

#132 datasciencesumit opened 5 years ago
0
connection error

#131 datasciencesumit opened 5 years ago
0
9

#130 vaibhavtupe closed 5 years ago
0
fixed md error on Readme coverage link

#129 diegoreico opened 5 years ago
0
spark-rabbitmq-0.5.1.jar run in Spark2.2.0 is ok,but not work in Spark2.3.0

#128 wssnail opened 5 years ago
6
Unable to create serializer "com.esotericsoftware.kryo.serializers.FieldSerializer" for class: org.apache.spark.streaming.rabbitmq.receiver.RabbitMQReceiver

#127 wssnail closed 5 years ago
1
Wrong variable name in test demo

#126 steelxiang opened 5 years ago
0
can't set vhost of rabbitmq

#125 steelxiang closed 5 years ago
0
Branch 0.5

#124 savithri123 closed 6 years ago
0
Please release a version with support for Apache Spark 2.2.x

#123 vetler opened 6 years ago
4
Minor fixes in README.md

#122 vetler closed 3 years ago
1
Change from pom to jar packaging to build JAR

#121 vetler closed 3 years ago
0
Upgrade to Apache Spark 2.2.0

#120 vetler closed 6 years ago
0
acknowledge message

#119 mantovani opened 6 years ago
6
Getting RabbitMQ Message Delivery Tag

#118 mantovani opened 6 years ago
4
Data Loss on failure

#117 kaveh-hariri opened 6 years ago
0
Streaming job fails due to connection shutdown

#116 atfire opened 7 years ago
5
java.lang.OutOfMemoryError: GC overhead limit exceeded

#115 Alanthur opened 7 years ago
11
Fixed typo in README.md

#114 yenki opened 7 years ago
0
Update stratio parent

#113 compae closed 7 years ago
0
Update spark 2.1.0 and akka version

#112 compae closed 7 years ago
0
Upgrading to akka 2.5.1

#111 avalcepina closed 7 years ago
1
java.io.IOException: java.lang.ClassNotFoundException: org.apache.spark.streaming.rabbitmq.receiver.RabbitMQReceiver

#110 dataExplor closed 7 years ago
2
Add possibility to specify SSL protocol

#109 jniebuhr opened 7 years ago
7
Non support disclaimer

#108 danielcsant closed 7 years ago
0
No option for SSL connection

#107 jniebuhr opened 7 years ago
4
Streaming does not stop

#106 tanroopdhillon opened 7 years ago
2
java.lang.ClassNotFoundException: org.apache.spark.streaming.rabbitmq.RabbitMQUtils

#105 rkamaleswaran opened 7 years ago
1
RabbitMQ Receiver fails with exception

#104 HardikkumarSoni opened 7 years ago
2
Consumers/Executors hanging

#103 kaveh-hariri opened 7 years ago
3
Unable to connect to rabbitmq container if spark is run in a docker container

#102 uladzimir-shelhunou closed 7 years ago
3
Error creating channel and connection: connection is already closed due to connection error; cause: com.rabbitmq.client.impl.UnknownChannelException: Unknown channel number 1

#101 alankala opened 7 years ago
6
Version related question

#100 airawat closed 7 years ago
1
Fixed : Wrong config parameter documentation

#99 ahvargas closed 7 years ago
2
java.lang.VerifyError: Inconsistent stackmap frames at branch target 152

#98 alankala opened 7 years ago
3
Wrong config parameter documentation causing default vHost to be used always

#97 charusheel closed 7 years ago
0
com.rabbitmq.client.ShutdownSignalException: connection error

#96 charusheel closed 7 years ago
1
No spark-rabbitmq-0.5.0.jar on Maven

#95 armaseg closed 7 years ago
3
Remove pom package in order to deploy jar in mvn central

#94 compae closed 7 years ago
0
Update README.md git link broken

#93 compae closed 7 years ago
1
Coverall includes updated

#92 compae closed 7 years ago
1
Coveralls link updated

#91 compae closed 7 years ago
0
Upgrade to Spark 2.0

#90 compae closed 7 years ago
0
Update version to last docker image and activate IT

#89 compae closed 7 years ago
0
Changelog to 0.4 version

#88 compae closed 7 years ago
0
Log messages with throwable

#87 compae closed 7 years ago
0