From ed8ddfedcd78d8df47301ed00710fd6ae9668e61 Mon Sep 17 00:00:00 2001 From: Michael Armbrust Date: Thu, 13 Aug 2015 17:54:00 -0700 Subject: [PATCH] yins comments --- src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala b/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala index 9a62bee..17088ab 100644 --- 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))