[
https://issues.apache.org/jira/browse/OOZIE-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Subhashrao Saley resolved OOZIE-2561.
--------------------------------------------
Resolution: Duplicate
> Child job url in case of child job failure
> ------------------------------------------
>
> Key: OOZIE-2561
> URL: https://issues.apache.org/jira/browse/OOZIE-2561
> Project: Oozie
> Issue Type: Bug
> Reporter: Satish Subhashrao Saley
> Assignee: Satish Subhashrao Saley
>
> Currently we are putting child job ids in output.properties in
> {code}
> protected static void writeExternalChildIDs(String logFile, Pattern[]
> patterns, String name) {
> // Harvesting and recording Hadoop Job IDs
> // See JavaActionExecutor#readExternalChildIDs for how they are read
> try {
> Properties jobIds = getHadoopJobIds(logFile, patterns);
> File file = new
> File(System.getProperty(LauncherMapper.ACTION_PREFIX
> + LauncherMapper.ACTION_DATA_OUTPUT_PROPS));
> OutputStream os = new FileOutputStream(file);
> try {
> jobIds.store(os, "");
> }
> finally {
> os.close();
> }
> System.out.println(" Hadoop Job IDs executed by " + name + ": " +
> jobIds.getProperty(HADOOP_JOBS));
> System.out.println();
> }
> catch (Exception e) {
> System.out.println("WARN: Error getting Hadoop Job IDs executed
> by " + name);
> e.printStackTrace(System.out);
> }
> }
> {code}
> We read from this file only in case of success of Launcher Main
> {code}
> In JavaActionExecutor:
> if (LauncherMapperHelper.isMainSuccessful(runningJob)) {
> if (getCaptureOutput(action) &&
> LauncherMapperHelper.hasOutputData(actionData)) {
> context.setExecutionData(SUCCEEDED,
> PropertiesUtils.stringToProperties(actionData
>
> .get(LauncherMapper.ACTION_DATA_OUTPUT_PROPS)));
> LOG.info(XLog.STD, "action produced output");
> }
> {code}
> We should write child job its to oozie.action.externalChildIDs. We need
> changes in following
> - HiveMain
> - Hive2Main
> - DistcpMain
> - SparkMain
> - SqoopMain
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
