private void setJobInstanceIdAndUri()

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());
            }
        }
    }