Re: Few issues and questions regarding streaming

2017-07-04 Thread Nikhil Utane
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.

Re: Few issues and questions regarding streaming

2017-07-04 Thread arpit tak
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