Typo fix for argument in sql

CODAIT · Oct 4, 2017 · 481bee2 · 481bee2
1 parent 378773e
commit 481bee2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cli/src/main/scala/com/ibm/sparktc/sparkbench/workload/sql/SQLWorkload.scala b/cli/src/main/scala/com/ibm/sparktc/sparkbench/workload/sql/SQLWorkload.scala
@@ -35,7 +35,7 @@ object SQLWorkload extends WorkloadDefaults {
   val name = "sql"
   def apply(m: Map[String, Any]) =
     new SQLWorkload(input = m.get("input").map(_.asInstanceOf[String]),
-      output = m.get("workloadresultsoutputdir").map(_.asInstanceOf[String]),
+      output = m.get("output").map(_.asInstanceOf[String]),
       queryStr = getOrThrow(m, "query").asInstanceOf[String],
       cache = getOrDefault[Boolean](m, "cache", false)
     )