I am trying to run the word count example but for some reason it's not working as expected. I start "nc" server on port 9999 and then submit the spark job to the cluster. Spark job gets successfully submitting but I never see any connection from spark getting established. I also tried to type words on the console where "nc" is listening and waiting on the prompt, however I don't see any output. I also don't see any errors.
Here is the conf: SparkConf conf = *new* SparkConf().setMaster(masterUrl).setAppName( "NetworkWordCount"); JavaStreamingContext *jssc* = *new* JavaStreamingContext(conf, Durations. *seconds*(1)); JavaReceiverInputDStream<String> lines = jssc.socketTextStream("localhost", 9999);