yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-27 01:45:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Ignore Entity No Change Events (#17087)

Browse Source
This commit is contained in:
Mohit Yadav 2024-07-19 01:16:50 +05:30 committed by GitHub
parent ebdd7f7fd9
commit 28218ec612
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
openmetadata-service/src/main/java/org/openmetadata/service/events/ChangeEventHandler.java
View File

@ -22,6 +22,7 @@ import javax.ws.rs.core.SecurityContext;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.openmetadata.schema.type.ChangeEvent; import org.openmetadata.schema.type.ChangeEvent;
import org.openmetadata.schema.type.EventType;
import org.openmetadata.service.Entity; import org.openmetadata.service.Entity;
import org.openmetadata.service.OpenMetadataApplicationConfig; import org.openmetadata.service.OpenMetadataApplicationConfig;
import org.openmetadata.service.util.JsonUtils; import org.openmetadata.service.util.JsonUtils;
@ -71,9 +72,11 @@ public class ChangeEventHandler implements EventHandler {
changeEvent.setEntity(JsonUtils.pojoToMaskedJson(entity)); changeEvent.setEntity(JsonUtils.pojoToMaskedJson(entity));
} }
// Thread are created in FeedRepository Directly // Insert ChangeEvents if ENTITY Changed
if (!changeEvent.getEventType().equals(EventType.ENTITY_NO_CHANGE)) {
Entity.getCollectionDAO().changeEventDAO().insert(JsonUtils.pojoToJson(changeEvent)); Entity.getCollectionDAO().changeEventDAO().insert(JsonUtils.pojoToJson(changeEvent));
} }
}
} catch (Exception e) { } catch (Exception e) {
LOG.error( LOG.error(
"Failed to capture the change event for method {} due to ", "Failed to capture the change event for method {} due to ",