Revision 39621
Added by Claudio Atzori over 8 years ago
| MinDistSearchHadoopJobNode.java | ||
|---|---|---|
| 132 | 132 |
|
| 133 | 133 |
final String counter = job.getParameters().get(UpdateCounterParam); |
| 134 | 134 |
if (StringUtils.isBlank(counter)) {
|
| 135 |
token.getFullEnv().setAttribute(StatusParam, STATUS.DATALOAD.toString()); |
|
| 135 | 136 |
log.info(String.format("done iteration %s:%s", UpdateCounterParam, 0));
|
| 136 | 137 |
engine.complete(token, Arc.DEFAULT_ARC); |
| 137 | 138 |
} else {
|
Also available in: Unified diff
when done reset default job status to DATALOAD