From f4e20af10764067e68c79df4dbf48768be4810d5 Mon Sep 17 00:00:00 2001 From: Yin Huai Date: Tue, 25 Aug 2015 23:31:50 -0700 Subject: [PATCH] fix typo --- src/main/scala/com/databricks/spark/sql/perf/tpcds/Tables.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/com/databricks/spark/sql/perf/tpcds/Tables.scala b/src/main/scala/com/databricks/spark/sql/perf/tpcds/Tables.scala index 620b077..1749440 100644 --- a/src/main/scala/com/databricks/spark/sql/perf/tpcds/Tables.scala +++ b/src/main/scala/com/databricks/spark/sql/perf/tpcds/Tables.scala @@ -124,7 +124,7 @@ class Tables(sqlContext: SQLContext, dsdgenDir: String, scaleFactor: Int) extend | $columnString |FROM | $tempTableName - |DISTRIBUTED BY + |DISTRIBUTE BY | $partitionColumnString """.stripMargin val grouped = sqlContext.sql(query)