Map绘制者是相互独立的，他们之间不可能有直接的交流。这么说来，没有直接的方式让mapper将失败传达给其他mapper。
如果您关心的是清理，那么可以在driver类中收集提交时作业的状态。

boolean done = job.waitForCompletion(true);

完成的值将是 false ，如果作业失败。如果它失败了（因为一个Map程序抛出了一个异常）；只需清理输出目录，或者通过编程修复csv并重新运行。
编辑-基于op的评论
作业设置为运行到最后并优雅地完成。也就是说，所有异常都被捕获并记录，因此Map程序不会被杀死。这意味着，作业的完成状态将始终是成功的。这样做是为了确保mapper在处理坏文件时不会失败，而是继续处理好的文件，直到最后一个文件。
在这种情况下，可以使用计数器（在Map器中）来增加失败的计数。

context.getCounter("my_group", "bad_record").increment(1);

当作业完成时，只需获取驱动程序类中的计数器值，如果进程的计数为正，则将其标记为失败。

long value= job.getCounters().getGroup("my_group").findCounter("bad_record").getValue();

请注意上面代码中的空检查，以防没有坏记录和计数器完全不存在。
编辑-添加另一个可能的选项
通过下面的代码，可以从上下文中获取job的示例，并尝试在Map器中获取计数器值（并停止进一步处理该文件）。但我不确定，计数器是在执行过程中还是仅在执行结束后才可用。

Configuration conf = context.getConfiguration();
Cluster cluster = new Cluster(conf);
Job currentJob = cluster.getJob(context.getJobID());
long val=currentJob.getCounters().findCounter("bad_record").getValue();

我没有测试过。请试着告诉我。