You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by fj...@apache.org on 2018/08/17 17:15:13 UTC
[incubator-druid] branch master updated: trigger clean dir when
unzip fails with IOException (#6178)
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 <ka...@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-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org