Repository: kylin Updated Branches: refs/heads/master 840a20870 -> 4a1b22c72
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/4a1b22c7 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/4a1b22c7 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/4a1b22c7 Branch: refs/heads/master Commit: 4a1b22c7230514a031c7aed938fb7751856ef3a2 Parents: 840a208 Author: lidongsjtu <lid...@apache.org> Authored: Mon Nov 7 09:57:01 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Mon Nov 7 11:40:51 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/4a1b22c7/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); }
