github/spark-sql-perf
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

comment

Browse Source
This commit is contained in:
Timothy Hunter 2016-06-28 12:00:04 -07:00
parent 5c1990e4ff
commit 353dc0c873
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala
View File

@ -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)
}

4
src/main/scala/com/databricks/spark/sql/perf/Benchmarkable.scala
View File

@ -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