OOZIE-2703 adding extra warning message if MR action check fails Change-Id: I9e7941fc0acdb1cb0bc6fe4f9828202b7da26d98
Project: http://git-wip-us.apache.org/repos/asf/oozie/repo Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/aa1dd961 Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/aa1dd961 Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/aa1dd961 Branch: refs/heads/oya Commit: aa1dd96133164a78ef8103154b50a2e1635733e4 Parents: 165847c Author: Peter Bacsko <pbac...@cloudera.com> Authored: Fri Oct 7 15:15:27 2016 +0200 Committer: Peter Bacsko <pbac...@cloudera.com> Committed: Fri Oct 7 15:15:27 2016 +0200 ---------------------------------------------------------------------- .../org/apache/oozie/action/hadoop/MapReduceActionExecutor.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oozie/blob/aa1dd961/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java b/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java index f7d230f..1b975ab 100644 --- a/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java +++ b/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java @@ -363,6 +363,7 @@ public class MapReduceActionExecutor extends JavaActionExecutor { jobCompleted = runningJob.isComplete(); } catch (Exception e) { LOG.warn("Exception in check(). Message[{0}]", e.getMessage(), e); + LOG.warn("Unable to check the state of a running MapReduce job - please check the health of the Job History Server!"); exception = true; throw convertException(e); } finally {