I just forgot to call start on the context.
Works now.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Java-Custom-Receiver-onStart-method-never-called-tp7525p7579.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
I create a Java custom receiver and then call
ssc.receiverStream(new MyReceiver("localhost", 8081)); // where ssc is the
JavaStreamingContext
I am expecting that the receiver's onStart method gets called but it does
not.
Can anyone give me some guidance? What am I not doing?
Here's the dependen