You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by pu...@apache.org on 2016/08/01 08:44:09 UTC
[09/50] [abbrv] lens git commit: LENS-1200 : Fix error message when
MR job failures happen
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 <pr...@apche.org>
Authored: Tue Jun 28 14:05:59 2016 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
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! ");
}