Scala Common Enrich: ensured that all timestamp fields are nonnegative (

closes #1938)
snowplow · Jan 14, 2016 · 71be005 · 71be005
1 parent 30bb789
commit 71be005
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...ain/scala/com.snowplowanalytics.snowplow.enrich/common/enrichments/EventEnrichments.scala b/...ain/scala/com.snowplowanalytics.snowplow.enrich/common/enrichments/EventEnrichments.scala
@@ -95,7 +95,12 @@ object EventEnrichments {
   val extractTimestamp: (String, String) => ValidatedString = (field, tstamp) =>
     try {
       val dt = new DateTime(tstamp.toLong)
-      toTimestamp(dt).success
+      val timestampString = toTimestamp(dt)
+      if (timestampString.startsWith("-")) {
+        s"Field [$field]: [$tstamp] is formatted as [$timestampString] which isn't Redshift-compatible".fail
+      } else {
+        timestampString.success
+      }
     } catch {
       case nfe: NumberFormatException =>
         "Field [%s]: [%s] is not in the expected format (ms since epoch)".format(field, tstamp).fail