Skip to content
Browse files

Merge pull request #8 from bm3780/master

JobConf Configuration should inherit from FileSystem's Configuration
  • Loading branch information...
2 parents 2b02081 + 803f5c9 commit 3c83f1fa926b44cf270881feda29878d2642011a @nathanmarz committed Apr 6, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/jvm/backtype/hadoop/Consolidator.java
View
2 src/jvm/backtype/hadoop/Consolidator.java
@@ -82,7 +82,7 @@ private static String getDirsString(List<String> targetDirs) {
public static void consolidate(FileSystem fs, RecordStreamFactory streams, PathLister lister, List<String> dirs,
long targetSizeBytes, String extension) throws IOException {
- JobConf conf = new JobConf(Consolidator.class);
+ JobConf conf = new JobConf(fs.getConf(), Consolidator.class);
String fsUri = fs.getUri().toString();
ConsolidatorArgs args = new ConsolidatorArgs(fsUri, streams, lister, dirs, targetSizeBytes, extension);
Utils.setObject(conf, ARGS, args);

0 comments on commit 3c83f1f

Please sign in to comment.
Something went wrong with that request. Please try again.