add datasource in intermediate segment path (apache#3961)

Gamehu · Feb 22, 2017 · edb032b · edb032b
1 parent 372b849
commit edb032b
Showing 1 changed file with 2 additions and 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
@@ -94,8 +94,9 @@ public DataSegment push(File inDir, DataSegment segment) throws IOException
     );
 
     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);