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);
