modified some errors.

tsudukim · tsudukim · commit 3f9a18841ed7 · 2015-05-12T09:13:31.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/PythonRunner.scala b/core/src/main/scala/org/apache/spark/deploy/PythonRunner.scala
@@ -19,10 +19,10 @@ package org.apache.spark.deploy
 
 import java.net.URI
 import java.io.File
-import scala.util.Try
 
 import scala.collection.mutable.ArrayBuffer
 import scala.collection.JavaConversions._
+import scala.util.Try
 
 import org.apache.spark.api.python.PythonUtils
 import org.apache.spark.util.{RedirectThread, Utils}
@@ -98,7 +98,7 @@ object PythonRunner {
 
     // In Windows, the drive should not be prefixed with "/"
     // For instance, python does not understand "/C:/path/to/sheep.py"
-    if (formattedPath.matches("/[a-zA-Z]:/.*")) {
+    if (Utils.isWindows && formattedPath.matches("/[a-zA-Z]:/.*")) {
       formattedPath = formattedPath.stripPrefix("/")
     }
     formattedPath
diff --git a/core/src/test/scala/org/apache/spark/deploy/PythonRunnerSuite.scala b/core/src/test/scala/org/apache/spark/deploy/PythonRunnerSuite.scala
@@ -18,6 +18,7 @@
 package org.apache.spark.deploy
 
 import org.scalatest.FunSuite
+
 import org.apache.spark.util.Utils
 
 class PythonRunnerSuite extends FunSuite {
@@ -29,9 +30,9 @@ class PythonRunnerSuite extends FunSuite {
     assert(PythonRunner.formatPath("file:///spark.py") === "/spark.py")
     assert(PythonRunner.formatPath("local:/spark.py") === "/spark.py")
     assert(PythonRunner.formatPath("local:///spark.py") === "/spark.py")
-    assert(PythonRunner.formatPath("file:/C:/a/b/spark.py", testWindows = true) ===
-      "C:/a/b/spark.py")
     if (Utils.isWindows) {
+      assert(PythonRunner.formatPath("file:/C:/a/b/spark.py", testWindows = true) ===
+        "C:/a/b/spark.py")
       assert(PythonRunner.formatPath("C:\\a\\b\\spark.py", testWindows = true) ===
         "C:/a/b/spark.py")
       assert(PythonRunner.formatPath("C:\\a b\\spark.py", testWindows = true) ===
diff --git a/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoop.scala b/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoop.scala
@@ -207,7 +207,7 @@ class SparkILoop(
         SparkILoop.getAddedJars.map { jar => new URI(jar).getPath.stripPrefix("/") }
       } else {
         // We need new URI(jar).getPath here for the case that `jar` includes encoded white space (%20).
-        SparkILoop.getAddedJars.map { jar => new URI(jar).getPath}
+        SparkILoop.getAddedJars.map { jar => new URI(jar).getPath }
       }
     // work around for Scala bug
     val totalClassPath = addedJars.foldLeft(

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,7 @@ class SparkILoop(`
`207`	`207`	`SparkILoop.getAddedJars.map { jar => new URI(jar).getPath.stripPrefix("/") }`
`208`	`208`	`} else {`
`209`	`209`	// We need new URI(jar).getPath here for the case that `jar` includes encoded white space (%20).
`210`		`- SparkILoop.getAddedJars.map { jar => new URI(jar).getPath}`
	`210`	`+ SparkILoop.getAddedJars.map { jar => new URI(jar).getPath }`
`211`	`211`	`}`
`212`	`212`	`// work around for Scala bug`
`213`	`213`	`val totalClassPath = addedJars.foldLeft(`