Don't materialize the RDD

apache · Feb 22, 2017 · c17fe2c · c17fe2c
1 parent bd37934
commit c17fe2c
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -181,7 +181,7 @@ class Dataset[T] private[sql](
       // For various commands (like DDL) and queries with side effects, we force query execution
       // to happen right away to let these side effects take place eagerly.
       case _: RunnableCommand =>
-        queryExecution.executedPlan.execute() // Trigger execution
+        queryExecution.executedPlan.executeToIterator() // Trigger execution
         MaterializedPlan(queryExecution.executedPlan)
       case _: Command =>
         // Note that there is currently no command that is not a RunnableCommand.