Merge pull request #57 from YotpoLtd/hotfix_redshiftOutputWriter

hotfix_redshiftOutputWriter
YotpoLtd · Dec 5, 2017 · e0141b0 · e0141b0
2 parents 03a195d + 574910c
commit e0141b0
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/main/scala/com/yotpo/metorikku/output/writers/redshift/RedshiftOutputWriter.scala b/src/main/scala/com/yotpo/metorikku/output/writers/redshift/RedshiftOutputWriter.scala
@@ -15,8 +15,11 @@ class RedshiftOutputWriter(metricOutputOptions: mutable.Map[String, String], red
 
   val log = LogManager.getLogger(this.getClass)
   val props = metricOutputOptions("outputOptions").asInstanceOf[Map[String, String]]
-  val maxStringSize = props.getOrElse("maxStringSize", "")
-  val dbOptions = RedshiftOutputProperties(SaveMode.valueOf(props("saveMode")), props("dbTable"), props("extraCopyOptions"), props("postActions"), maxStringSize)
+  val dbOptions = RedshiftOutputProperties(SaveMode.valueOf(props("saveMode")),
+                                           props("dbTable"),
+                                           props.getOrElse("extraCopyOptions",""),
+                                           props.getOrElse("postActions",""),
+                                           props.getOrElse("maxStringSize",""))
 
   override def write(dataFrame: DataFrame): Unit = {
     redshiftDBConf match {