Repository: kylin Updated Branches: refs/heads/yang21 1b2efcd7a -> f439676dd
minor, job diagnosis extract conf for each mr job Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/f439676d Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/f439676d Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/f439676d Branch: refs/heads/yang21 Commit: f439676dd87e2ce2448d19428ca9b6e01868d4fc Parents: 1b2efcd Author: lidongsjtu <lid...@apache.org> Authored: Mon Nov 7 09:57:01 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Mon Nov 7 09:57:05 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/tool/MrJobInfoExtractor.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/f439676d/tool/src/main/java/org/apache/kylin/tool/MrJobInfoExtractor.java ---------------------------------------------------------------------- diff --git a/tool/src/main/java/org/apache/kylin/tool/MrJobInfoExtractor.java b/tool/src/main/java/org/apache/kylin/tool/MrJobInfoExtractor.java index 056c210..96f47d3 100644 --- a/tool/src/main/java/org/apache/kylin/tool/MrJobInfoExtractor.java +++ b/tool/src/main/java/org/apache/kylin/tool/MrJobInfoExtractor.java @@ -127,13 +127,9 @@ public class MrJobInfoExtractor extends AbstractInfoExtractor { try { String jobResponse = getHttpResponse(jobUrlPrefix); JsonNode job = new ObjectMapper().readTree(jobResponse).path("job").get("state"); - String state = job.textValue(); - logger.debug(state); - if (!state.equals("SUCCEEDED")) { - String confUrl = jobUrlPrefix + "/conf/"; - String response = getHttpResponse(confUrl); - FileUtils.writeStringToFile(new File(exportDir, "job_conf.json"), response, Charset.defaultCharset()); - } + String confUrl = jobUrlPrefix + "/conf/"; + String response = getHttpResponse(confUrl); + FileUtils.writeStringToFile(new File(exportDir, "job_conf.json"), response, Charset.defaultCharset()); } catch (Exception e) { logger.warn("Failed to get job conf rest response.", e); }
