diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/CollectionDAO.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/CollectionDAO.java index 8fa92bb2891..5fb38e7ed65 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/CollectionDAO.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/CollectionDAO.java @@ -1020,13 +1020,13 @@ public interface CollectionDAO { value = "DELETE FROM entity_relationship " + "WHERE JSON_UNQUOTE(JSON_EXTRACT(json, '$.source')) = :source AND toId = :toId AND toEntity = :toEntity " - + "AND relation = :relation ORDER BY fromId", + + "AND relation = :relation", connectionType = MYSQL) @ConnectionAwareSqlUpdate( value = "DELETE FROM entity_relationship " + "WHERE json->>'source' = :source AND (toId = :toId AND toEntity = :toEntity) " - + "AND relation = :relation ORDER BY fromId", + + "AND relation = :relation", connectionType = POSTGRES) void deleteLineageBySource( @BindUUID("toId") UUID toId,