diff --git a/shims/0.23/src/main/java/org/apache/hadoop/mapred/WebHCatJTShim23.java b/shims/0.23/src/main/java/org/apache/hadoop/mapred/WebHCatJTShim23.java index c85a739..6b91db4 100644 --- a/shims/0.23/src/main/java/org/apache/hadoop/mapred/WebHCatJTShim23.java +++ b/shims/0.23/src/main/java/org/apache/hadoop/mapred/WebHCatJTShim23.java @@ -139,7 +139,7 @@ private RunningJob getJob(JobID jobid) throws IOException { } catch(IOException ex) { String msg = ex.getMessage(); - if(msg != null && msg.contains("ApplicationNotFoundException")) { + if(msg != null && (msg.contains("ApplicationNotFoundException") || msg.contains("History file"))) { LOG.info("Job(" + jobid + ") not found: " + msg); return null; }