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)