You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by ge...@apache.org on 2016/10/10 11:52:49 UTC
[50/50] [abbrv] oozie git commit: OOZIE-2703 adding extra warning
message if MR action check fails
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 <pb...@cloudera.com>
Authored: Fri Oct 7 15:15:27 2016 +0200
Committer: Peter Bacsko <pb...@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 {