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 dependency info: <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming_2.10</artifactId> <version>1.0.0</version> </dependency> Thanks for your help -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Java-Custom-Receiver-onStart-method-never-called-tp7525.html Sent from the Apache Spark User List mailing list archive at Nabble.com.