Revision 48800
Added by Claudio Atzori over 6 years ago
| AbstractHadoopAction.java | ||
|---|---|---|
| 57 | 57 |
|
| 58 | 58 |
@Override |
| 59 | 59 |
public void execute(final BlackboardServerHandler handler, final BlackboardJob job) {
|
| 60 |
executor.execute(new Runnable() {
|
|
| 61 |
|
|
| 62 |
@Override |
|
| 63 |
public void run() {
|
|
| 64 |
try {
|
|
| 65 |
handler.ongoing(job); |
|
| 66 |
executeAsync(handler, job); |
|
| 67 |
} catch (final Throwable e) {
|
|
| 68 |
log.error(ExceptionUtils.getFullStackTrace(e)); |
|
| 69 |
handler.failed(job, e); |
|
| 70 |
} |
|
| 60 |
executor.execute(() -> {
|
|
| 61 |
try {
|
|
| 62 |
handler.ongoing(job); |
|
| 63 |
executeAsync(handler, job); |
|
| 64 |
} catch (final Throwable e) {
|
|
| 65 |
log.error(ExceptionUtils.getFullStackTrace(e)); |
|
| 66 |
handler.failed(job, e); |
|
| 71 | 67 |
} |
| 72 | 68 |
}); |
| 73 | 69 |
} |
Also available in: Unified diff
more logging in the oozie job monitor procedure that tries to fetch the job report. More java8 refactorings