diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java index 8244274..dcffb16 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java @@ -168,6 +168,10 @@ public AppConfig() { init(); LOG.info("Using Hadoop version " + VersionInfo.getVersion()); } + + public AppConfig(AppConfig appConf) { + super(appConf); + } private void init() { for (Map.Entry e : System.getenv().entrySet()) diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java index 27b8e38..b3e5096 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java @@ -1026,7 +1026,12 @@ else if ((jobid != null && job.compareTo(jobid) > 0) || jobid == null) { JobItemBean jobItem = new JobItemBean(); jobItem.id = job; if (showDetails) { - StatusDelegator sd = new StatusDelegator(appConf); + //The global JobClient retry is too aggressive for this operation, + //remove the retry to avoid timeouts + final AppConfig sdConf = new AppConfig(appConf); + sdConf.set("mapreduce.jobclient.getjob.max.retry", "1"); + sdConf.set("yarn.app.mapreduce.client.job.max-retries", "0"); + StatusDelegator sd = new StatusDelegator(sdConf); try { jobItem.detail = sd.run(getDoAsUser(), job); }