Revision 48650
Added by Claudio Atzori over 6 years ago
| modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/oozie/OozieJobMonitor.java | ||
|---|---|---|
| 87 | 87 |
* Provides report entries when found for given oozie job identifier. Returns null when report not found. |
| 88 | 88 |
*/ |
| 89 | 89 |
private static Properties getReport(final OozieClient oozieClient, final String oozieJobId, final Set<String> workflowActions) throws OozieClientException, IOException {
|
| 90 |
WorkflowJob mainIisWfJob = oozieClient.getJobInfo(oozieJobId); |
|
| 91 |
for (WorkflowAction currentAction : mainIisWfJob.getActions()) {
|
|
| 90 |
WorkflowJob oozieJob = oozieClient.getJobInfo(oozieJobId); |
|
| 91 |
for (WorkflowAction currentAction : oozieJob.getActions()) {
|
|
| 92 |
log.debug(String.format("looking for workflo actions to report, current: '%s'", currentAction.getName()));
|
|
| 92 | 93 |
if (workflowActions.contains(currentAction.getName())) {
|
| 93 | 94 |
if (ACTION_TYPE_SUBWORKFLOW.equals(currentAction.getType())) {
|
| 94 | 95 |
Properties subworkflowProperties = getReport(oozieClient, currentAction.getExternalId(), workflowActions); |
Also available in: Unified diff
using proper names for variables :)