Skip to content

Commit 9e7a11a

Browse files
fblundunjbeemster
authored andcommitted
Kinesis LZO S3 Sink: added special treatment for "us-east-1" region (see #1327)
1 parent cbd3388 commit 9e7a11a

File tree

1 file changed

+4
-1
lines changed
  • src/main/scala/com.snowplowanalytics.snowplow.storage.kinesis/s3

1 file changed

+4
-1
lines changed

src/main/scala/com.snowplowanalytics.snowplow.storage.kinesis/s3/SinkApp.scala

+4-1
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,10 @@ object SinkApp extends App {
104104

105105
val s3 = connector.getConfig("s3")
106106
val s3Region = s3.getString("region")
107-
val s3Endpoint = s"https://s3-$s3Region.amazonaws.com"
107+
val s3Endpoint = s3Region match {
108+
case "us-east-1" => "https://s3.amazonaws.com"
109+
case _ => s"https://s3-$s3Region.amazonaws.com"
110+
}
108111
val bucket = s3.getString("bucket")
109112

110113
val buffer = connector.getConfig("buffer")

0 commit comments

Comments
 (0)