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 8102337..b0b9d55 100644 --- a/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala +++ b/src/main/scala/com/databricks/spark/sql/perf/Benchmark.scala @@ -212,7 +212,9 @@ abstract class Benchmark( try { val resultsTable = sqlContext.createDataFrame(results) currentMessages += s"Results written to table: 'sqlPerformance' at $resultsLocation/$timestamp" - results.toDF().write + results.toDF() + .coalesce(1) + .write .format("json") .save(s"$resultsLocation/$timestamp")