嗨，我正在运行一个应用程序，从hbase读取记录并写入文本文件。
我在应用程序中使用了组合器，也使用了自定义分区器。我在应用程序中使用了41 reducer，因为我需要创建40 reducer输出文件，以满足自定义分区器中的条件。
所有工作正常，但当我在我的应用程序中使用组合器，它创建每个区域或每个Map器的Map输出文件。
例如，我的应用程序中有40个区域，因此启动了40个Map程序，然后创建了40个Map输出文件。但是reducer不能合并所有的map输出并生成最终的reducer输出文件，该文件将是40个reducer输出文件。
文件中的数据是正确的，但没有任何文件增加。
你知道我怎么才能只得到减速机输出文件吗。

import java.io.IOException;
import org.apache.log4j.Logger;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.lib.output.MultipleOutputs;
public class CommonCombiner extends Reducer<NullWritable, Text, NullWritable, Text> {
    private Logger logger = Logger.getLogger(CommonCombiner.class);
    private MultipleOutputs<NullWritable, Text> multipleOutputs;
    String strName = "";
    private static final String DATA_SEPERATOR = "\\|\\!\\|";
    public void setup(Context context) {
        logger.info("Inside Combiner.");
        multipleOutputs = new MultipleOutputs<NullWritable, Text>(context);
    }
    @Override
    public void reduce(NullWritable Key, Iterable<Text> values, Context context)
            throws IOException, InterruptedException {
        for (Text value : values) {
            final String valueStr = value.toString();
            StringBuilder sb = new StringBuilder();
            if ("".equals(strName) && strName.length() == 0) {
                String[] strArrFileName = valueStr.split(DATA_SEPERATOR);
                String strFullFileName[] = strArrFileName[1].split("\\|\\^\\|");
                strName = strFullFileName[strFullFileName.length - 1];
                String strArrvalueStr[] = valueStr.split(DATA_SEPERATOR);
                if (!strArrvalueStr[0].contains(HbaseBulkLoadMapperConstants.FF_ACTION)) {
                    sb.append(strArrvalueStr[0] + "|!|");
                }
                multipleOutputs.write(NullWritable.get(), new Text(sb.toString()), strName);
                context.getCounter(Counters.FILE_DATA_COUNTER).increment(1);
            }
        }
    }
    public void cleanup(Context context) throws IOException, InterruptedException {
        multipleOutputs.close();
    }
}