Hi,
I've finally fixed this. The problem was that I wasn't providing a type for
the DStream in ssc.actorStream
/* with this inputDStream : ReceiverInputDStream[Nothing] and we get
SparkDriverExecutionException: Execution error
* Caused by: java.lang.ArrayStoreException: [Ljava.lang.Object;
Hi,
I'm trying to create a Spark Streaming actor stream but I'm having several
problems. First of all the guide from
https://spark.apache.org/docs/latest/streaming-custom-receivers.html refers
to the code
https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples