RE: Python : StreamingContext isn't created properly

2016-08-03 Thread Paolo Patierno
e.com To: user@spark.apache.org Subject: Python : StreamingContext isn't created properly Date: Wed, 3 Aug 2016 14:16:22 + Hi all, I wrote following function in Python : def createStreamingContext(): conf = (SparkConf().setMaster("local[2]").setAppName

Python : StreamingContext isn't created properly

2016-08-03 Thread Paolo Patierno
Hi all, I wrote following function in Python : def createStreamingContext(): conf = (SparkConf().setMaster("local[2]").setAppName("my_app")) conf.set("spark.streaming.receiver.writeAheadLog.enable", "true") sc = SparkContext(conf=conf) ssc = StreamingContext(sc, 1)