You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ji...@apache.org on 2017/02/21 09:04:28 UTC
eagle git commit: [MINOR] add Job error category and error message
mapping
Repository: eagle
Updated Branches:
refs/heads/master 45a649399 -> 3fe82b817
[MINOR] add Job error category and error message mapping
Author: wujinhu <wu...@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 <wu...@126.com>
Authored: Tue Feb 21 17:04:21 2017 +0800
Committer: wujinhu <wu...@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));