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

Reply via email to