protected Map retryLivyGetAppId()

in service/src/main/java/org/apache/griffin/core/job/LivyTaskSubmitHelper.java [183:220]

31 lines of code
7 McCabe index (conditional complexity)


    protected Map<String, Object> retryLivyGetAppId(String result, int appIdRetryCount)
        throws IOException {

        int retryCount = appIdRetryCount;
        TypeReference<HashMap<String, Object>> type =
            new TypeReference<HashMap<String, Object>>() {
            };
        Map<String, Object> resultMap = toEntity(result, type);

        if (retryCount <= 0) {
            return null;
        }

        if (resultMap.get("appId") != null) {
            return resultMap;
        }

        Object livyBatchesId = resultMap.get("id");
        if (livyBatchesId == null) {
            return resultMap;
        }

        while (retryCount-- > 0) {
            try {
                Thread.sleep(SLEEP_TIME);
            } catch (InterruptedException e) {
                LOGGER.error(e.getMessage(), e);
            }
            resultMap = getResultByLivyId(livyBatchesId, type);
            LOGGER.info("retry get livy resultMap: {}, batches id : {}", resultMap, livyBatchesId);

            if (resultMap.get("appId") != null) {
                break;
            }
        }

        return resultMap;
    }