我有两个mapper类，它们从同一个文件夹中获取一些文件作为输入，并根据具有时间戳的文件名确定必须将该文件作为输入的mapper。有时，同一个输入文件会作为输入提供给两个不同的Map器。现在我已经测试过，当两个不同的输入都给了两个Map器时，它可以工作，但是当我给它们相同的输入时，其中一个Map器类不会生成用于在reducer中进行比较的结果。
代码是巨大的，所以我不把它放在这里，我会描述我做了什么。我创建了两个列表并扫描了目录中的文件，根据有时间戳的文件名，我将它们放在两个不同的列表中，然后将它们添加到两个不同的Map器中，即它们的计算方式都不同，因此我使用不同的Map器进行计算，然后在reducer中进行比较，但当输入文件与两个Map器的时间条件几乎相同时，其中一个Map器不会生成任何结果。所以这是因为一个Map程序不能访问文件，因为另一个正在使用它，如果是这样的话，有什么办法可以绕过它。
这里mappath1是一个列表，而mappath2是另一个列表

for(i=0;i<MapPath1.size();i++)
      MultipleInputs.addInputPath(job,new Path(MapPath1.get(i)),TextInputFormat.class,Map1.class);
if(type.equals("comparative"))
      for(i=0;i<MapPath2.size();i++)
            MultipleInputs.addInputPath(job,new Path(MapPath2.get(i)),TextInputFormat.class,Map2.class);

更新
我刚刚发现这个问题（hadoop中的多个Map器）与我的问题类似，但我不想复制输入文件，因为它可能很大。任何一个可以指导我如何创建两个不同的工作使用不同的Map器，并提供给一个单一的减速机。