fix: sending an individual email when having one grouped error

easy-global-market · Sep 27, 2024 · c9ff997 · c9ff997
1 parent acc5e71
commit c9ff997
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ovenance-reporting-tasks/src/main/java/io/egm/nifi/reporting/EmailProvenanceReporter.java b/...ovenance-reporting-tasks/src/main/java/io/egm/nifi/reporting/EmailProvenanceReporter.java
@@ -328,7 +328,7 @@ private String composeMessageContent(final Map<String, Object> event, Boolean gr
             .append("\tProcessor type: ").append(event.get("component_type")).append("\n")
             .append("\tProcess group: ").append(event.get("process_group_name")).append("\n");
 
-        if (groupSimilarErrors) {
+        if (groupSimilarErrors && groupedEventsSize > 1) {
             message.append("\tTotal similar errors : ").append(groupedEventsSize).append("\n");
         }
 
@@ -417,7 +417,7 @@ public void sendErrorEmail(Map<String, Object> event, ReportingContext context,
             emailSubjectBuilder.append("[").append(subjectPrefix).append("] ");
         }
 
-        if (groupSimilarErrors) {
+        if (groupSimilarErrors && groupedEventsSize > 1) {
             emailSubjectBuilder.append(groupedEventsSize).append(" errors occurred in processor ")
                 .append(event.get("component_name")).append(" in process group ")
                 .append(event.get("process_group_name"));