mapreduce压缩

如图，我对map输出进行了压缩，但是报了一个空指针异常，不知道怎么回事

改成下面形式：


conf.setBoolean("mapred.output.compress", true);

conf.setClass("mapred.map.output.compression.codec", GzipCodec.class, CompressionCodec.class);

muyannian 发表于 2015-11-7 18:23
改成下面形式：

我是想压缩map输出的，并不是给reduce压缩