Hi, I am using hadoop 0.20.0 release version. I was trying to enable intermediate output compression from code. (libhadoop.so.* was put in /usr/lib) I tried the following and it didnt give me the desired effect. Doing the same using old API seemed to work( JobConf.setCompressMapOutput(true))
See the code below. Configuration conf = new Configuration(); conf.set("mapred.compress.map.output", "true"); conf.set("mapred.output.compression.type", "BLOCK"); conf.set("mapred.output.compress", "org.apache.hadoop.io.compress.GzipCodec"); Job job = new Job(conf, "Generating dataset based from input"); Please help Robin