From 4396cada65523af47eb71d36a89ec335cb95e5ac Mon Sep 17 00:00:00 2001 From: Teddy Date: Thu, 14 Sep 2023 11:37:36 +0200 Subject: [PATCH] fix: use entityLink FQN vs entityFQN when checking against entity FQN in alerting (#13189) --- .../service/events/subscription/AlertsRuleEvaluator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/events/subscription/AlertsRuleEvaluator.java b/openmetadata-service/src/main/java/org/openmetadata/service/events/subscription/AlertsRuleEvaluator.java index 4049eab4a0e..5960a4d1919 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/events/subscription/AlertsRuleEvaluator.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/events/subscription/AlertsRuleEvaluator.java @@ -29,6 +29,7 @@ import org.openmetadata.schema.type.FieldChange; import org.openmetadata.schema.type.Include; import org.openmetadata.service.Entity; import org.openmetadata.service.formatter.util.FormatterUtil; +import org.openmetadata.service.resources.feeds.MessageParser; import org.openmetadata.service.util.JsonUtils; @Slf4j @@ -102,7 +103,8 @@ public class AlertsRuleEvaluator { } EntityInterface entity = getEntity(changeEvent); for (String name : entityNames) { - if (changeEvent.getEntityType().equals(TEST_CASE) && ((TestCase) entity).getEntityFQN().equals(name)) { + if (changeEvent.getEntityType().equals(TEST_CASE) + && (MessageParser.EntityLink.parse(((TestCase) entity).getEntityLink()).getEntityFQN().equals(name))) { return true; } if (entity.getFullyQualifiedName().equals(name)) {