我正在使用ooziesqoop操作在datalake中导入数据。我需要一个hdfs文件夹为每个表的数据库源。我有300多张table。
我可以将所有300 sqoop操作硬编码到一个工作流中，但是工作流对于oozie配置来说太大了。

Error submitting job /user/me/workflow.xml
E0736: Workflow definition length [107,123] exceeded maximum allowed length [100,000]

拥有这样的大文件不是一个好主意，因为它会减慢系统的速度（它保存在数据库中），而且很难维护。
问题是，如何为每个表名调用子工作流？
等效的shell脚本类似于：

while read TABLE; do
  sqoop import --connect ${CONNECT} --username ${USERNAME} --password ${PASSWORD} --table ${TABLE} --target-dir ${HDFS_LOCATION}/${TABLE} --num-mappers ${NUM-MAPPERS}
done < tables.data

其中tables.data包含一个表名列表，该列表是数据库源表名的子集。例如：

TABLE_ONE
TABLE_TWO
TABLE_SIX
TABLE_TEN

下面是我要为每个表调用的子工作流：

<workflow-app name="sub-workflow-import-table" xmlns="uri:oozie:workflow:0.5">
    <start to="sqoop-import"/>
    <action name="sqoop-import">
        <sqoop xmlns="uri:oozie:sqoop-action:0.2">
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <command>sqoop import --connect ${CONNECT} --username ${USERNAME} --password ${PASSWORD} --table ${TABLE} --target-dir ${HDFS_LOCATION}/${TABLE} --num-mappers ${NUM-MAPPERS}</command>
        </sqoop>
        <ok to="end"/>
        <error to="log-and-kill"/>
    </action>
    <end name="end"/>
    <kill name="log-and-kill">
        <message>Workflow failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
    </kill>
</workflow-app>

如果你需要更精确的信息，请告诉我。谢谢！大卫