in service/src/main/java/org/apache/griffin/core/job/JobServiceImpl.java [619:636]
private void setJobInstanceIdAndUri(JobInstanceBean instance, HashMap<String
, Object> resultMap) {
if (resultMap != null) {
Object state = resultMap.get("state");
Object appId = resultMap.get("appId");
instance.setState(state == null ? null : LivySessionStates.State
.valueOf(state.toString().toUpperCase
()));
instance.setAppId(appId == null ? null : appId.toString());
instance.setAppUri(appId == null ? null : env
.getProperty("yarn.uri") + "/cluster/app/" + appId);
instanceRepo.save(instance);
// If Livy returns to success or dead, task execution completes one,TaskNum--
if (instance.getState().equals(SUCCESS) || instance.getState().equals(DEAD)) {
livyTaskSubmitHelper.decreaseCurTaskNum(instance.getSessionId());
}
}
}