From 206d0fe56180718196a60066ac7e8c65e0ebc218 Mon Sep 17 00:00:00 2001 From: wujinhu Date: Tue, 21 Feb 2017 17:01:07 +0800 Subject: [PATCH 1/2] add Job error category and error message mapping --- .../apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java | 1 + 1 file changed, 1 insertion(+) 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 afcd7be656..87d90cd8ad 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 @@ protected void handleJob(EventType eventType, Map values, Object t 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)); From b2122e656841f35fdc165acc8aeeff981ae7c4c8 Mon Sep 17 00:00:00 2001 From: wujinhu Date: Tue, 21 Feb 2017 23:20:31 +0800 Subject: [PATCH 2/2] fix mr history null pointer bug --- .../apache/eagle/jpm/mr/history/parser/JHFEventReaderBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 87d90cd8ad..0502d1f0db 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 @@ -133,7 +133,7 @@ public JHFEventReaderBase(Map baseTags, Configuration configurat this.appConfig = appConfig; this.jobCounterMetricsGenerator = new JobCounterMetricsGenerator(appConfig.getEagleServiceConfig()); this.jobSuggestionListener = new JobSuggestionListener(appConfig.getConfig()); - this.addListener(jobSuggestionListener); + //this.addListener(jobSuggestionListener); } public void register(HistoryJobEntityLifecycleListener lifecycleListener) {