aboutsummaryrefslogtreecommitdiff
path: root/repl/src
diff options
context:
space:
mode:
Diffstat (limited to 'repl/src')
-rw-r--r--repl/src/test/scala/org/apache/spark/repl/ReplSuite.scala6
1 files changed, 4 insertions, 2 deletions
diff --git a/repl/src/test/scala/org/apache/spark/repl/ReplSuite.scala b/repl/src/test/scala/org/apache/spark/repl/ReplSuite.scala
index 4155007c6d..e33f4f9803 100644
--- a/repl/src/test/scala/org/apache/spark/repl/ReplSuite.scala
+++ b/repl/src/test/scala/org/apache/spark/repl/ReplSuite.scala
@@ -25,6 +25,7 @@ import scala.collection.mutable.ArrayBuffer
import com.google.common.io.Files
import org.scalatest.FunSuite
import org.apache.spark.SparkContext
+import org.apache.commons.lang3.StringEscapeUtils
class ReplSuite extends FunSuite {
@@ -185,11 +186,12 @@ class ReplSuite extends FunSuite {
out.close()
val output = runInterpreter("local",
"""
- |var file = sc.textFile("%s/input").cache()
+ |var file = sc.textFile("%s").cache()
|file.count()
|file.count()
|file.count()
- """.stripMargin.format(tempDir.getAbsolutePath))
+ """.stripMargin.format(StringEscapeUtils.escapeJava(
+ tempDir.getAbsolutePath + File.separator + "input")))
assertDoesNotContain("error:", output)
assertDoesNotContain("Exception", output)
assertContains("res0: Long = 3", output)