Cómo configurar el flujo de trabajo de oozie para la ruta de múltiples entradas con múltiples mapeadores

¿Puede alguien ayudarme a configurar un flujo de trabajo con la acción Map-Reduce, que toma múltiples rutas de entrada? Cada ruta de entrada está asociada a un Mapper como, por ejemplo, MultipleInputs.addInputPath api toma la ruta de entrada y un Mapper. La salida de estos mapeadores se dará a reductor.

Intenté esto con acción java, pero solo ejecutará una tarea de mapa. Pero aquí la ruta de entrada contiene datos enormes, por lo que la acción java no lo haremos en este caso.

¿Hay alguna manera de manejar este caso?

Saludos, Krish.

Respuestas a la pregunta(1)

Su respuesta a la pregunta