These three lines of python code cause the error for me:
sc = SparkContext(appName="foo")
input = sc.textFile("hdfs://[valid hdfs path]")
mappedToLines = input.map(lambda myline: myline.split(","))
The file I'm loading is a simple CSV.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Python-script-runs-fine-in-local-mode-errors-in-other-modes-tp12390p12398.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
