Thanks for your response Arpit.
As per my understanding, only SparkContext is created. We have to create
the StreamingContext. The example that I am following is for Zeppelin where
StreamingContext is being created.
Now my problem is, I am getting a socket error while running my streaming
example.
Hi Nikhil,
First, Spark context and streaming context already defined in zeppelin when you
write code , you don’t need to initialize it again as we generally do in
writing normal spark code.
Second, you just need to start ssc.start() once and if your next paragraph is
linked to first note then