diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/DatabaseSchemaRepository.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/DatabaseSchemaRepository.java index 559558343c9..b1bc0e9dadc 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/DatabaseSchemaRepository.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/DatabaseSchemaRepository.java @@ -92,7 +92,7 @@ public class DatabaseSchemaRepository extends EntityRepository { if (schema == null) { return null; } - List tableIds = findTo(schema.getId(), Entity.DATABASE, Relationship.CONTAINS, Entity.TABLE); + List tableIds = findTo(schema.getId(), Entity.DATABASE_SCHEMA, Relationship.CONTAINS, Entity.TABLE); return EntityUtil.populateEntityReferences(tableIds, Entity.TABLE); }