Revision 27483
Added by Claudio Atzori over 10 years ago
| modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/oozie/OozieJobMonitor.java | ||
|---|---|---|
| 55 | 55 |
return; |
| 56 | 56 |
} else {
|
| 57 | 57 |
// TODO retrieve some failure information from the oozie client. |
| 58 |
String msg = "hadoop job: " + getHadoopId() + " failed with status: " + getStatus(); |
|
| 58 |
String msg = "hadoop job: " + getHadoopId() + " failed with status: " + getStatus() + ", oozie log:\n " |
|
| 59 |
+ getOozieClient().getJobLog(getHadoopId()) + "\n\n"; |
|
| 59 | 60 |
getCallback().failed(msg, new HadoopServiceException(msg)); |
| 60 | 61 |
return; |
| 61 | 62 |
} |
| modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/action/SubmitMapreduceJobAction.java | ||
|---|---|---|
| 79 | 79 |
|
| 80 | 80 |
@Override |
| 81 | 81 |
public void failed(String msg, Throwable e) {
|
| 82 |
log.error(msg);
|
|
| 82 |
log.debug(msg);
|
|
| 83 | 83 |
handler.failed(bbJob, e); |
| 84 | 84 |
decrementRunningJobs(jobName); |
| 85 | 85 |
} |
| modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/action/SubmitOozieJobAction.java | ||
|---|---|---|
| 67 | 67 |
|
| 68 | 68 |
@Override |
| 69 | 69 |
public void failed(String msg, Throwable e) {
|
| 70 |
log.error(msg);
|
|
| 70 |
log.debug(msg);
|
|
| 71 | 71 |
handler.failed(bbJob, e); |
| 72 | 72 |
decrementRunningJobs(jobName); |
| 73 | 73 |
} |
Also available in: Unified diff
better logging