Revision 60425
Added by Claudio Atzori about 3 years ago
| modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/oozie/OozieJobMonitor.java | ||
|---|---|---|
| 69 | 69 |
} |
| 70 | 70 |
} |
| 71 | 71 |
|
| 72 |
log.info(format("looking for oozie job(%s) output values: %s", getHadoopId(), workflowActions));
|
|
| 72 |
log.debug(format("looking for oozie job(%s) output values: %s", getHadoopId(), workflowActions));
|
|
| 73 | 73 |
Map<String, String> report = getReport(getOozieClient(), getHadoopId(), workflowActions); |
| 74 | 74 |
|
| 75 |
log.debug(format("job %s finished with status: %s", jobId, status));
|
|
| 75 |
log.info(format("job %s finished with status: %s", jobId, status));
|
|
| 76 | 76 |
if (Status.SUCCEEDED.equals(status)) {
|
| 77 | 77 |
getCallback().done(report); |
| 78 | 78 |
|
Also available in: Unified diff
updated hadoop aggregation workflow reporting