yins comments

2015-08-13 17:54:00 -07:00 · 2015-08-13 17:54:00 -07:00 · ed8ddfedcd
commit ed8ddfedcd
parent 4101a1e968
1 changed files with 1 additions and 1 deletions
--- a/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala
+++ b/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala
@ -429,7 +429,7 @@ abstract class Benchmark(@transient protected val sqlContext: SQLContext)
              messages += s"Breakdown: ${node.simpleString}"
              val newNode = buildDataFrame.queryExecution.executedPlan(index)
              val executionTime = benchmarkMs {
-                node.execute().foreach((row: Any) => Unit)
+                newNode.execute().foreach((row: Any) => Unit)
              }
              timeMap += ((index, executionTime))