From 16a0c40d4cb1f801f22640361578c60f8b3d0d01 Mon Sep 17 00:00:00 2001
From: Charles Allen <charles@allen-net.com>
Date: Fri, 24 Apr 2015 15:06:28 -0700
Subject: [PATCH] Fix concatenated gzip files in StaticS3FirehoseFactory

---
 .../java/io/druid/firehose/s3/StaticS3FirehoseFactory.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/extensions/s3-extensions/src/main/java/io/druid/firehose/s3/StaticS3FirehoseFactory.java b/extensions/s3-extensions/src/main/java/io/druid/firehose/s3/StaticS3FirehoseFactory.java
index 76963105179..400fe77481e 100644
--- a/extensions/s3-extensions/src/main/java/io/druid/firehose/s3/StaticS3FirehoseFactory.java
+++ b/extensions/s3-extensions/src/main/java/io/druid/firehose/s3/StaticS3FirehoseFactory.java
@@ -25,6 +25,7 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Throwables;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
+import com.metamx.common.CompressionUtils;
 import com.metamx.common.logger.Logger;
 import io.druid.data.input.Firehose;
 import io.druid.data.input.FirehoseFactory;
@@ -113,7 +114,7 @@ public class StaticS3FirehoseFactory implements FirehoseFactory<StringInputRowPa
                                                            .getDataInputStream();
 
               final InputStream outerInputStream = s3Object.getKey().endsWith(".gz")
-                                                   ? new GZIPInputStream(innerInputStream)
+                                                   ? CompressionUtils.gzipInputStream(innerInputStream)
                                                    : innerInputStream;
 
               return IOUtils.lineIterator(