[incubator-druid] branch master updated: trigger clean dir when unzip fails with IOException (#6178)

[fjy]

This is an automated email from the ASF dual-hosted git repository.

fjy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git


The following commit(s) were added to refs/heads/master by this push:
     new 78fc5b2  trigger clean dir when unzip fails with IOException (#6178)
78fc5b2 is described below

commit 78fc5b246c30c12d247b85daff0f54e67cab2ce6
Author: kaijianding <kaijian.d...@gmail.com>
AuthorDate: Sat Aug 18 01:15:10 2018 +0800

    trigger clean dir when unzip fails with IOException (#6178)
---
 .../java/io/druid/storage/azure/AzureDataSegmentPullerTest.java     | 6 ++----
 .../src/main/java/io/druid/java/util/common/CompressionUtils.java   | 3 +++
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/extensions-contrib/azure-extensions/src/test/java/io/druid/storage/azure/AzureDataSegmentPullerTest.java
 
b/extensions-contrib/azure-extensions/src/test/java/io/druid/storage/azure/AzureDataSegmentPullerTest.java
index 8c0b058..97139bc 100644
--- 
a/extensions-contrib/azure-extensions/src/test/java/io/druid/storage/azure/AzureDataSegmentPullerTest.java
+++ 
b/extensions-contrib/azure-extensions/src/test/java/io/druid/storage/azure/AzureDataSegmentPullerTest.java
@@ -90,12 +90,10 @@ public class AzureDataSegmentPullerTest extends 
EasyMockSupport
     final File outDir = Files.createTempDirectory("druid").toFile();
     try {
       expect(azureStorage.getBlobInputStream(containerName, 
blobPath)).andThrow(
-          new StorageException(
+          new URISyntaxException(
               "error",
               "error",
-              404,
-              null,
-              null
+              404
           )
       );
 
diff --git 
a/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java 
b/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java
index 2fc4a37..99c6367 100644
--- a/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java
+++ b/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java
@@ -169,6 +169,9 @@ public class CompressionUtils
             DEFAULT_RETRY_COUNT
         );
       }
+      catch (IOException e) {
+        throw e;
+      }
       catch (Exception e) {
         throw Throwables.propagate(e);
       }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org