diff --git a/workflow-engine/src/main/java/com/redhat/parodos/workflows/workflow/ParallelFlowReport.java b/workflow-engine/src/main/java/com/redhat/parodos/workflows/workflow/ParallelFlowReport.java
index d81f56c88..b494d0f01 100644
--- a/workflow-engine/src/main/java/com/redhat/parodos/workflows/workflow/ParallelFlowReport.java
+++ b/workflow-engine/src/main/java/com/redhat/parodos/workflows/workflow/ParallelFlowReport.java
@@ -26,7 +26,6 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 
 import com.redhat.parodos.workflows.work.WorkContext;
 import com.redhat.parodos.workflows.work.WorkReport;
@@ -148,8 +147,7 @@ public WorkContext getWorkContext() {
 
 	@Override
 	public String getAlertMessage() {
-		return reports.stream().map(WorkReport::getAlertMessage).filter(Objects::nonNull)
-				.reduce((first, second) -> second).orElse(null);
+		return reports.stream().reduce((first, second) -> second).map(WorkReport::getAlertMessage).orElse(null);
 	}
 
 }
diff --git a/workflow-engine/src/test/java/com/redhat/parodos/workflows/workflow/ParallelFlowReportTest.java b/workflow-engine/src/test/java/com/redhat/parodos/workflows/workflow/ParallelFlowReportTest.java
index 2e1478934..7ceb0e4f8 100644
--- a/workflow-engine/src/test/java/com/redhat/parodos/workflows/workflow/ParallelFlowReportTest.java
+++ b/workflow-engine/src/test/java/com/redhat/parodos/workflows/workflow/ParallelFlowReportTest.java
@@ -84,7 +84,7 @@ public void testGetReports() {
 	@Test
 	public void testGetAlertMessage() {
 		assertThat(completedParallelFlowReport.getAlertMessage()).isEqualTo("alertMessage_2");
-		assertThat(failedParallelFlowReport.getAlertMessage()).isEqualTo("alertMessage_1");
+		assertThat(failedParallelFlowReport.getAlertMessage()).isNull();
 		assertThat(progressParallelFlowReport.getAlertMessage()).isEqualTo("alertMessage_3");
 	}