From 28218ec61273ead3fc79f451a3e69bdde9c3eb33 Mon Sep 17 00:00:00 2001
From: Mohit Yadav <105265192+mohityadav766@users.noreply.github.com>
Date: Fri, 19 Jul 2024 01:16:50 +0530
Subject: [PATCH] Ignore Entity No Change Events (#17087)

---
 .../openmetadata/service/events/ChangeEventHandler.java    | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/events/ChangeEventHandler.java b/openmetadata-service/src/main/java/org/openmetadata/service/events/ChangeEventHandler.java
index 287edcbe47d..82d59d4aa82 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/events/ChangeEventHandler.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/events/ChangeEventHandler.java
@@ -22,6 +22,7 @@ import javax.ws.rs.core.SecurityContext;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.openmetadata.schema.type.ChangeEvent;
+import org.openmetadata.schema.type.EventType;
 import org.openmetadata.service.Entity;
 import org.openmetadata.service.OpenMetadataApplicationConfig;
 import org.openmetadata.service.util.JsonUtils;
@@ -71,8 +72,10 @@ public class ChangeEventHandler implements EventHandler {
           changeEvent.setEntity(JsonUtils.pojoToMaskedJson(entity));
         }
 
-        // Thread are created in FeedRepository Directly
-        Entity.getCollectionDAO().changeEventDAO().insert(JsonUtils.pojoToJson(changeEvent));
+        // Insert ChangeEvents if ENTITY Changed
+        if (!changeEvent.getEventType().equals(EventType.ENTITY_NO_CHANGE)) {
+          Entity.getCollectionDAO().changeEventDAO().insert(JsonUtils.pojoToJson(changeEvent));
+        }
       }
     } catch (Exception e) {
       LOG.error(