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

fix hdfs config

This commit is contained in:
fjy 2013-06-28 10:18:10 -07:00
parent cce62cbd8b
commit 5a57539736
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/com/metamx/druid/loading/HdfsDataSegmentPusher.java
View File

@ -43,7 +43,7 @@ public class HdfsDataSegmentPusher implements DataSegmentPusher
public DataSegment push(File inDir, DataSegment segment) throws IOException public DataSegment push(File inDir, DataSegment segment) throws IOException
{ {
final String storageDir = DataSegmentPusherUtil.getStorageDir(segment); final String storageDir = DataSegmentPusherUtil.getStorageDir(segment);
Path outFile = new Path(String.format("%s/%s/index.zip", config.getStorageDirectory(), storageDir)); Path outFile = config.getStorageDirectory().suffix(String.format("/%s/index.zip", storageDir));
FileSystem fs = outFile.getFileSystem(hadoopConfig); FileSystem fs = outFile.getFileSystem(hadoopConfig);
fs.mkdirs(outFile.getParent()); fs.mkdirs(outFile.getParent());

3
server/src/main/java/com/metamx/druid/loading/HdfsDataSegmentPusherConfig.java
View File

@ -19,6 +19,7 @@
package com.metamx.druid.loading; package com.metamx.druid.loading;
import org.apache.hadoop.fs.Path;
import org.skife.config.Config; import org.skife.config.Config;
import java.io.File; import java.io.File;
@ -28,5 +29,5 @@ import java.io.File;
public abstract class HdfsDataSegmentPusherConfig public abstract class HdfsDataSegmentPusherConfig
{ {
@Config("druid.pusher.hdfs.storageDirectory") @Config("druid.pusher.hdfs.storageDirectory")
public abstract File getStorageDirectory(); public abstract Path getStorageDirectory();
} }