Permalink
Browse files

allow jobConf to inherit from FileSystem's configuration

  • Loading branch information...
bm3780 committed Mar 16, 2012
1 parent 2b02081 commit 803f5c99d9259a637bd95e59a39fe9e498e45926
Showing with 1 addition and 1 deletion.
  1. +1 −1 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 803f5c9

Please sign in to comment.