[MINOR] [PYSPARK] Set PYTHONPATH to python/lib/pyspark.zip rather than python/pyspark

Sephiroth-Lin · jeanlyn · commit bee93f20a421 · 2015-05-28T19:12:17.000+08:00
As PR apache#5580 we have created pyspark.zip on building and set PYTHONPATH to python/lib/pyspark.zip, so to keep consistence update this. Author: linweizhong <linweizhong@huawei.com> Closes apache#6047 from Sephiroth-Lin/pyspark_pythonpath and squashes the following commits: 8cc3d96 [linweizhong] Set PYTHONPATH to python/lib/pyspark.zip rather than python/pyspark as PR#5580 we have create pyspark.zip on build
diff --git a/core/src/main/scala/org/apache/spark/api/python/PythonUtils.scala b/core/src/main/scala/org/apache/spark/api/python/PythonUtils.scala
@@ -31,7 +31,7 @@ private[spark] object PythonUtils {
   def sparkPythonPath: String = {
     val pythonPath = new ArrayBuffer[String]
     for (sparkHome <- sys.env.get("SPARK_HOME")) {
-      pythonPath += Seq(sparkHome, "python").mkString(File.separator)
+      pythonPath += Seq(sparkHome, "python", "lib", "pyspark.zip").mkString(File.separator)
       pythonPath += Seq(sparkHome, "python", "lib", "py4j-0.8.2.1-src.zip").mkString(File.separator)
     }
     pythonPath ++= SparkContext.jarOfObject(this)

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ private[spark] object PythonUtils {`
`31`	`31`	`def sparkPythonPath: String = {`
`32`	`32`	`val pythonPath = new ArrayBuffer[String]`
`33`	`33`	`for (sparkHome <- sys.env.get("SPARK_HOME")) {`
`34`		`- pythonPath += Seq(sparkHome, "python").mkString(File.separator)`
	`34`	`+ pythonPath += Seq(sparkHome, "python", "lib", "pyspark.zip").mkString(File.separator)`
`35`	`35`	`pythonPath += Seq(sparkHome, "python", "lib", "py4j-0.8.2.1-src.zip").mkString(File.separator)`
`36`	`36`	`}`
`37`	`37`	`pythonPath ++= SparkContext.jarOfObject(this)`