Update Dataset.scala

JoshRosen · web-flow · commit 07e4c8f6b87a · 2016-09-12T17:58:36.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
@@ -2572,7 +2572,7 @@ class Dataset[T] private[sql](
       val toJava: (Any) => Any = EvaluatePython.toJava(_, schema)
       val iter = new SerDeUtil.AutoBatchedPickler(
         queryExecution.executedPlan.executeCollect().iterator.map(toJava))
-      PythonRDD.serveIterator(iter, s"serve-DataFrame")
+      PythonRDD.serveIterator(iter, "serve-DataFrame")
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -2572,7 +2572,7 @@ class Dataset[T] private[sql](`
`2572`	`2572`	`val toJava: (Any) => Any = EvaluatePython.toJava(_, schema)`
`2573`	`2573`	`val iter = new SerDeUtil.AutoBatchedPickler(`
`2574`	`2574`	`queryExecution.executedPlan.executeCollect().iterator.map(toJava))`
`2575`		`- PythonRDD.serveIterator(iter, s"serve-DataFrame")`
	`2575`	`+ PythonRDD.serveIterator(iter, "serve-DataFrame")`
`2576`	`2576`	`}`
`2577`	`2577`	`}`
`2578`	`2578`