From 353dc0c8733ad6ccf95d8fe27678164928b44bf3 Mon Sep 17 00:00:00 2001 From: Timothy Hunter Date: Tue, 28 Jun 2016 12:00:04 -0700 Subject: [PATCH] comment --- src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala | 2 +- .../scala/com/databricks/spark/sql/perf/Benchmarkable.scala | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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 f354ce2..4ff08ea 100644 --- a/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala +++ b/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala @@ -108,7 +108,7 @@ abstract class Benchmark( forkThread: Boolean = true) = { new ExperimentStatus(executionsToRun, includeBreakdown, iterations, variations, tags, - timeout, resultLocation, sqlContext, allTables, currentConfiguration) + timeout, resultLocation, sqlContext, allTables, currentConfiguration, forkThread = forkThread) } diff --git a/src/main/scala/com/databricks/spark/sql/perf/Benchmarkable.scala b/src/main/scala/com/databricks/spark/sql/perf/Benchmarkable.scala index d8c7148..6303843 100644 --- a/src/main/scala/com/databricks/spark/sql/perf/Benchmarkable.scala +++ b/src/main/scala/com/databricks/spark/sql/perf/Benchmarkable.scala @@ -45,9 +45,9 @@ trait Benchmarkable extends Logging { sparkContext.setJobDescription(s"Execution: $name, $description") beforeBenchmark() val result = if (forkThread) { - doBenchmark(includeBreakdown, description, messages) - } else { runBenchmarkForked(includeBreakdown, description, messages, timeout) + } else { + doBenchmark(includeBreakdown, description, messages) } afterBenchmark(sqlContext.sparkContext) result