Revision 60355
Added by Claudio Atzori about 3 years ago
AbstractSubmitAction.java | ||
---|---|---|
135 | 135 |
return new JobCompletion() { |
136 | 136 |
|
137 | 137 |
@Override |
138 |
public void done(final Map<String, String> properties) {
|
|
139 |
bbJob.getParameters().putAll(properties);
|
|
140 |
log.info(String.format("%s completed successfully, returning %s output params", jobName, properties.size()));
|
|
138 |
public void done(final Map<String, String> report) {
|
|
139 |
bbJob.getParameters().putAll(report);
|
|
140 |
log.info(String.format("%s completed successfully, returning %s output params", jobName, report.size()));
|
|
141 | 141 |
handler.done(bbJob); |
142 | 142 |
decrementRunningJobs(jobName); |
143 | 143 |
} |
144 | 144 |
|
145 | 145 |
@Override |
146 |
public void failed(final String msg, final Throwable e) { |
|
147 |
log.debug(msg); |
|
146 |
public void failed(final Map<String, String> report, final String msg, final Throwable e) { |
|
147 |
bbJob.getParameters().putAll(report); |
|
148 |
log.error(String.format("%s failed, returning %s output params", jobName, report.size())); |
|
148 | 149 |
handler.failed(bbJob, e); |
149 | 150 |
decrementRunningJobs(jobName); |
150 | 151 |
} |
Also available in: Unified diff
catch output params from the different oozie workflow actions