From cb7ac88bb4f28f49f1da6cf1333ba8a295ffa089 Mon Sep 17 00:00:00 2001
From: david-leifker <114954101+david-leifker@users.noreply.github.com>
Date: Fri, 13 Sep 2024 08:01:02 -0500
Subject: [PATCH] fix(NPE): fix NPE in EntityService (#11373)

---
 .../java/com/linkedin/metadata/entity/EntityServiceImpl.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/metadata-io/src/main/java/com/linkedin/metadata/entity/EntityServiceImpl.java b/metadata-io/src/main/java/com/linkedin/metadata/entity/EntityServiceImpl.java
index c584b8ac4d..69135a8a64 100644
--- a/metadata-io/src/main/java/com/linkedin/metadata/entity/EntityServiceImpl.java
+++ b/metadata-io/src/main/java/com/linkedin/metadata/entity/EntityServiceImpl.java
@@ -1041,6 +1041,7 @@ public class EntityServiceImpl implements EntityService<ChangeItemImpl> {
             inputBatch,
             DEFAULT_MAX_TRANSACTION_RETRY)
         .stream()
+        .filter(Objects::nonNull)
         .flatMap(List::stream)
         .collect(Collectors.toList());
   }