Repository: eagle Updated Branches: refs/heads/master 45a649399 -> 3fe82b817
[MINOR] add Job error category and error message mapping Author: wujinhu <[email protected]> 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 <[email protected]> Authored: Tue Feb 21 17:04:21 2017 +0800 Committer: wujinhu <[email protected]> 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));
