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