diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TableRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TableRepository.java index 0247bf0b7cd..308b7adbd8e 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TableRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TableRepository.java @@ -1138,7 +1138,7 @@ public class TableRepository extends EntityRepository { String toParent = FullyQualifiedName.getParentFQN(column); String columnName = FullyQualifiedName.getColumnName(column); try { - Table toTable = findByName(toParent, NON_DELETED); + Table toTable = findByName(toParent, ALL); validateColumn(toTable, columnName); } catch (EntityNotFoundException e) { throw new EntitySpecViolationException("Table not found: " + toParent); @@ -1232,8 +1232,7 @@ public class TableRepository extends EntityRepository
{ for (String column : constraint.getReferredColumns()) { String toParent = FullyQualifiedName.getParentFQN(column); try { - EntityReference toTable = - Entity.getEntityReferenceByName(TABLE, toParent, NON_DELETED); + EntityReference toTable = Entity.getEntityReferenceByName(TABLE, toParent, ALL); addRelationship( table.getId(), toTable.getId(), TABLE, TABLE, Relationship.RELATED_TO); } catch (EntityNotFoundException e) {