Hadoop Driver类双Job执行异常：第二个Job的Reducer未运行求助

兄弟，我帮你梳理下第二个Job的Reducer没跑起来的常见原因，这些都是实际开发中容易踩的坑：

1. 确认Reducer类的配置是否完整 #

• 首先检查Job2的代码里有没有明确设置Reducer类：job.setReducerClass(YourFinalReducer.class)，别漏写或者写错类名了。
• 还要确保Reducer的输出键值类型配置正确：job.setOutputKeyClass(...)和job.setOutputValueClass(...)。如果Mapper的输出类型和Reducer的输入类型不匹配，Hadoop会直接跳过Reducer，把Mapper的输出当最终结果。

2. 检查输入数据和Mapper的输出 #

• 如果第二个Job的输入是第一个Job的输出，先确认第一个Job的输出目录里有实际的数据文件（不是只有_SUCCESS空文件）。
• 可以在第二个Mapper里加个日志输出（比如System.out.println或者用Hadoop的LOG.info），看看有没有生成键值对。要是Mapper没输出任何数据，Reducer肯定不会执行。

3. 千万别误设Reduce任务数为0 #

这是最常见的坑！如果你的代码里不小心写了job.setNumReduceTasks(0)，Hadoop会直接跳过Reduce阶段，把Mapper的输出直接写到结果目录里。一定要确保Job2里要么不设置这个参数（默认会根据集群情况分配），要么明确设为大于0的数，比如job.setNumReduceTasks(1)。

4. 检查输出路径的权限和存在性 #

• 如果输出路径已经存在，Hadoop默认会报错终止任务，但要是你配置了允许覆盖（FileOutputFormat.setOutputPath(job, path)之前加FileSystem.get(conf).delete(path, true)），也要确认路径有读写权限，尤其是本地模式下，权限不足可能导致Reducer无法写入，但这种情况一般日志里会有报错。

5. 查看Hadoop任务日志找线索 #

去Hadoop的Web管理页面（比如ResourceManager默认8088端口）找到第二个Job的详情，看看Reducer任务的状态：

• 要是根本没启动，大概率是前面的配置问题；
• 要是启动后失败了，看日志里的具体错误，比如类型转换异常、内存不足这些，都能精准定位问题。

给你贴个正确的Job2配置示例，参考下：

// 初始化第二个Job
Job job2 = Job.getInstance(conf, "SecondProcessingJob");
job2.setJarByClass(Driver.class);

// 设置Mapper和Reducer类
job2.setMapperClass(SecondMapper.class);
job2.setReducerClass(YourFinalReducer.class);

// 配置输出键值类型（要和Reducer的输出一致）
job2.setOutputKeyClass(Text.class);
job2.setOutputValueClass(IntWritable.class);

// 设置输入输出路径
FileInputFormat.addInputPath(job2, new Path(firstJobOutputDir));
FileOutputFormat.setOutputPath(job2, new Path(secondJobOutputDir));

// 确保Reduce任务数大于0
job2.setNumReduceTasks(1);

// 提交Job并等待完成
job2.waitForCompletion(true);

内容的提问来源于stack exchange，提问作者Kumar Harsh