Merge pull request #138 from neojunjie/es-upgrade

feat(gms): add delete events into es index
aqden · Nov 27, 2023 · 1a1fac1 · 1a1fac1
2 parents 7a2941c + df7dea8
commit 1a1fac1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...a-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/hook/UpdateIndicesHook.java b/...a-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/hook/UpdateIndicesHook.java
@@ -238,6 +238,9 @@ private void handleDeleteChangeEvent(@Nonnull final MetadataChangeLog event) {
       deleteGraphData(urn, aspectSpec, aspect, isDeletingKey, event);
       deleteSearchData(urn, entitySpec.getName(), aspectSpec, aspect, isDeletingKey);
     }
+
+    // Populate update index with delete event
+    updateUpdateIndex(event);
   }
 
   // TODO: remove this method once we implement sourceOverride when creating graph edges