From edb032b96df8581440d4fb450dc470e47c5c4859 Mon Sep 17 00:00:00 2001 From: Parag Jain Date: Wed, 22 Feb 2017 16:31:00 -0600 Subject: [PATCH] add datasource in intermediate segment path (#3961) --- .../main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java b/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java index 47dd748962d..953ab23c5db 100644 --- a/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java +++ b/extensions-core/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java @@ -94,8 +94,9 @@ public class HdfsDataSegmentPusher implements DataSegmentPusher ); Path tmpFile = new Path(String.format( - "%s/%s/index.zip", + "%s/%s/%s/index.zip", fullyQualifiedStorageDirectory, + segment.getDataSource(), UUIDUtils.generateUuid() )); FileSystem fs = tmpFile.getFileSystem(hadoopConfig);