3

Hadoop Map/Reduce ジョブで奇妙な問題が発生しています。ジョブは正しく送信され、実行されますが、正しくない/奇妙な結果が生成されます。マッパーとリデューサーがまったく実行されていないようです。入力ファイルは次から変換されます。

12
16
132
654
132
12

に

0   12
4   16
8   132
13  654
18  132
23  12

最初の列はマッパーの前にペアに対して生成されたキーであると想定していますが、マッパーもリデューサーも実行されていないようです。古い API を使用した場合、ジョブは正常に実行されました。

ジョブのソースを以下に示します。プラットフォームとして Hortonworks を使用しています。

public class HadoopAnalyzer
{
    public static class Map extends Mapper<LongWritable, Text, Text, IntWritable>
    {
        private final static IntWritable one = new IntWritable(1);
        private Text word = new Text();

        @Override
        public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException
        {
            String line = value.toString();
            StringTokenizer tokenizer = new StringTokenizer(line);
            while (tokenizer.hasMoreTokens())
            {
                word.set(tokenizer.nextToken());
                context.write(word, one);
            }
        }
    }

    public static class Reduce extends Reducer<Text, IntWritable, Text, IntWritable>
    {
        @Override
        public void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException
        {
            int sum = 0;
            for (IntWritable val : values)
            {
                sum += val.get();
            }
            context.write(key, new IntWritable(sum));
        }
    }

    public static void main(String[] args) throws Exception
    {
        JobConf conf = new JobConf(HadoopAnalyzer.class);
        conf.setJobName("wordcount");
        conf.set("mapred.job.tracker", "192.168.229.128:50300");
        conf.set("fs.default.name", "hdfs://192.168.229.128:8020");
        conf.set("fs.defaultFS", "hdfs://192.168.229.128:8020");
        conf.set("hbase.master", "192.168.229.128:60000");
        conf.set("hbase.zookeeper.quorum", "192.168.229.128");
        conf.set("hbase.zookeeper.property.clientPort", "2181");
        System.out.println("Executing job.");
        Job job = new Job(conf, "job");
        job.setInputFormatClass(InputFormat.class);
        job.setOutputFormatClass(OutputFormat.class);
        job.setJarByClass(HadoopAnalyzer.class);
        job.setInputFormatClass(TextInputFormat.class);
        job.setOutputFormatClass(TextOutputFormat.class);
        TextInputFormat.addInputPath(job, new Path("/user/usr/in"));
        TextOutputFormat.setOutputPath(job, new Path("/user/usr/out"));
        job.setMapperClass(Mapper.class);
        job.setReducerClass(Reducer.class);
        job.waitForCompletion(true);
        System.out.println("Done.");
    }
}

明らかな何かが欠けているかもしれませんが、ここで何がうまくいかないのか、誰かが光を当てることができますか?

4

1 に答える 1

3

以下を使用したため、出力は期待どおりです。

job.setMapperClass(Mapper.class);
job.setReducerClass(Reducer.class);

あるべきだったのは --

job.setMapperClass(Map.class);
job.setReducerClass(Reduce.class);

Mapper と Reducer クラスを Map と Reduce で拡張しましたが、ジョブでは使用しませんでした。

于 2013-10-04T16:00:28.723 に答える