Repository: kylin Updated Branches: refs/heads/v1.6.0-rc1 75c981cb3 -> 4e5f989b9
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/8385850b Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/8385850b Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/8385850b Branch: refs/heads/v1.6.0-rc1 Commit: 8385850bc78ca8797aa070b33196c7f707d7aef0 Parents: 75c981c Author: lidongsjtu <lid...@apache.org> Authored: Mon Nov 7 09:57:01 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Mon Nov 7 11:41:57 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/8385850b/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); }
