Eu tenho um script de shell que executasqoop job. O script está abaixo.

!#/bin/bash

table=$1

sqoop job --exec ${table}

Agora, quando passo o nome da tabela no fluxo de trabalho, obtenho que o trabalho do sqoop seja executado com sucesso.

O fluxo de trabalho está abaixo.

<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>

O trabalho é executado com êxito para a tabelatest123.

Agora eu tenho 300 trabalhos sqoop, como acima. Eu quero executar 10 trabalhos sqoop em paralelo. Todos os nomes de tabela estão em um único arquivo.

Agora, quero fazer um loop no arquivo e executar 10 tarefas sqoop nas primeiras 10 tabelas e assim por diante.

Como posso fazer isso? devo preparar 10 fluxos de trabalho? Estou literalmente confuso.