add datasource in intermediate segment path (#3961)

2017-02-22 16:31:00 -06:00 · 2017-02-22 16:31:00 -06:00 · edb032b96d
parent 372b84991c
commit edb032b96d
1 changed files with 2 additions and 1 deletions
--- 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);