eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinh...@apache.org
Subject eagle git commit: [MINOR] add Job error category and error message mapping
Date Tue, 21 Feb 2017 09:04:28 GMT
Repository: eagle
Updated Branches:
  refs/heads/master 45a649399 -> 3fe82b817


[MINOR] add Job error category and error message mapping

Author: wujinhu <wujinhu920@126.com>

Closes #829 from wujinhu/EAGLE-845.


Project: http://git-wip-us.apache.org/repos/asf/eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/eagle/commit/3fe82b81
Tree: http://git-wip-us.apache.org/repos/asf/eagle/tree/3fe82b81
Diff: http://git-wip-us.apache.org/repos/asf/eagle/diff/3fe82b81

Branch: refs/heads/master
Commit: 3fe82b81768887b42b019c43178887261f984a9b
Parents: 45a6493
Author: wujinhu <wujinhu920@126.com>
Authored: Tue Feb 21 17:04:21 2017 +0800
Committer: wujinhu <wujinhu920@126.com>
Committed: Tue Feb 21 17:04:21 2017 +0800

----------------------------------------------------------------------
 .../org/apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java  | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/eagle/blob/3fe82b81/eagle-jpm/eagle-jpm-mr-history/src/main/java/org/apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java
----------------------------------------------------------------------
diff --git a/eagle-jpm/eagle-jpm-mr-history/src/main/java/org/apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java
b/eagle-jpm/eagle-jpm-mr-history/src/main/java/org/apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java
index afcd7be..87d90cd 100644
--- a/eagle-jpm/eagle-jpm-mr-history/src/main/java/org/apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java
+++ b/eagle-jpm/eagle-jpm-mr-history/src/main/java/org/apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java
@@ -314,6 +314,7 @@ public abstract class JHFEventReaderBase extends JobEntityCreationPublisher
impl
                 jobErrorCategoryMappingAPIEntity.setTags(new HashMap<>(jobExecutionEntity.getTags()));
                 jobErrorCategoryMappingAPIEntity.getTags().put(MRJobTagName.ERROR_CATEGORY.toString(),
errorCategory);
                 jobErrorCategoryMappingAPIEntity.setTimestamp(jobExecutionEntity.getTimestamp());
+                jobErrorCategoryMappingAPIEntity.setTaskAttempts(new ArrayList<>());
 
                 for (String taskId : errorCategoryTaskMapping.get(errorCategory).keySet())
{
                     jobErrorCategoryMappingAPIEntity.getTaskAttempts().add(errorCategoryTaskMapping.get(errorCategory).get(taskId));


Mime
View raw message