Tengo un script de shell que se ejecutasqoop job. El guión está abajo.

!#/bin/bash

table=$1

sqoop job --exec ${table}

Ahora, cuando paso el nombre de la tabla en el flujo de trabajo, obtengo el trabajo sqoop para que se ejecute correctamente.

El flujo de trabajo está debajo.

<workflow-app name="Shell_script" xmlns="uri:oozie:workflow:0.5">
<start to="shell"/>
<kill name="Kill">
    <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
</kill>
<action name="shell_script">
    <shell xmlns="uri:oozie:shell-action:0.1">
        <job-tracker>${jobTracker}</job-tracker>
        <name-node>${nameNode}</name-node>
        <exec>sqoopjob.sh</exec>
        <argument>test123</argument>
        <file>/user/oozie/sqoop/lib/sqoopjob.sh#sqoopjob.sh</file>
    </shell>
    <ok to="End"/>
    <error to="Kill"/>
    </action>
    <end name="End"/>
</workflow-app>

El trabajo se ejecuta correctamente para la tabla.test123.

Ahora tengo 300 trabajos sqoop igual que el anterior. Quiero ejecutar 10 trabajos sqoop en paralelo. Todos los nombres de las tablas están en un solo archivo.

Ahora quiero recorrer el archivo y ejecutar 10 trabajos sqoop para las primeras 10 tablas, etc.

¿Cómo puedo hacer esto? ¿Debo preparar 10 flujos de trabajo? Estoy literalmente confundido.