Github user jerryshao commented on a diff in the pull request: https://github.com/apache/spark/pull/20382#discussion_r164934753 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ConsoleWriter.scala --- @@ -56,7 +58,7 @@ trait ConsoleWriter extends Logging { println("-------------------------------------------") // scalastyle:off println spark - .createDataFrame(spark.sparkContext.parallelize(rows), schema) + .createDataFrame(rows.toList.asJava, schema) --- End diff -- OK, I will create a separate PR for this small fix.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org