LENS-1200 : Fix error message when MR job failures happen
Project: http://git-wip-us.apache.org/repos/asf/lens/repo Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/5f79cc6b Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/5f79cc6b Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/5f79cc6b Branch: refs/heads/current-release-line Commit: 5f79cc6b216b8fc864c1cca34b929b6e9cc868cb Parents: 600b9be Author: Rajat Khandelwal <[email protected]> Authored: Tue Jun 28 14:05:59 2016 +0530 Committer: Amareshwari Sriramadasu <[email protected]> Committed: Tue Jun 28 14:05:59 2016 +0530 ---------------------------------------------------------------------- .../src/main/java/org/apache/lens/driver/hive/HiveDriver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/lens/blob/5f79cc6b/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java ---------------------------------------------------------------------- diff --git a/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java b/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java index 88de651..28b77c8 100644 --- a/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java +++ b/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java @@ -655,7 +655,7 @@ public class HiveDriver extends AbstractLensDriver { if (tstate == Task.TaskState.FINISHED) { completedTasks++; } - if (taskStat.getErrorMsg() != null) { + if ((taskStat.getReturnValue() != null && taskStat.getReturnValue() != 0) || taskStat.getErrorMsg() != null) { appendTaskIds(errorMessage, taskStat); errorMessage.append(" has failed! "); }
