Stream Enrich: fix incorrect parsing of S3 urls (fixes #2921)

snowplow · Nov 15, 2016 · a769b19 · a769b19
1 parent cb3920e
commit a769b19
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nrich/src/main/scala/com.snowplowanalytics.snowplow.enrich/kinesis/KinesisEnrichApp.scala b/...nrich/src/main/scala/com.snowplowanalytics.snowplow.enrich/kinesis/KinesisEnrichApp.scala
@@ -155,7 +155,7 @@ object KinesisEnrichApp extends App {
     val targetFile = new File(uriFilePair._2)
 
     // Ensure uri does not have doubled slashes
-    val cleanUri = new java.net.URI(uriFilePair._1.toString.replaceAll("(?<!(http:|https:))//", "/"))
+    val cleanUri = new java.net.URI(uriFilePair._1.toString.replaceAll("(?<!(http:|https:|s3:))//", "/"))
 
     // Download the database file if it doesn't already exist or is empty
     // See http://stackoverflow.com/questions/10281370/see-if-file-is-empty