Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

path should already be a proper uri 

works around issues when config cannot properly initialize early
in the indexing process
This commit is contained in:
Xavier Léauté 2014-03-27 14:51:08 -07:00
parent 183a133ee4
commit c4402cc84d
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentPusher.java
View File

@ -66,12 +66,7 @@ public class HdfsDataSegmentPusher implements DataSegmentPusher
@Override
public String getPathForHadoop(String dataSource)
{
try {
return new Path(config.getStorageDirectory(), dataSource).makeQualified(FileSystem.get(hadoopConfig)).toString();
}
catch (IOException e) {
throw Throwables.propagate(e);
}
return new Path(config.getStorageDirectory(), dataSource).toUri().toString();
}
@Override