diff --git a/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/database/trinoConnection.json b/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/database/trinoConnection.json
index a4a7342c4ff..b456e0b3bcd 100644
--- a/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/database/trinoConnection.json
+++ b/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/database/trinoConnection.json
@@ -92,5 +92,5 @@
     }
   },
   "additionalProperties": false,
-  "required": ["hostPort", "username"]
+  "required": ["hostPort", "username", "catalog"]
 }
diff --git a/ingestion/src/metadata/ingestion/source/trino.py b/ingestion/src/metadata/ingestion/source/trino.py
index 124f309686a..3cdf16682ba 100644
--- a/ingestion/src/metadata/ingestion/source/trino.py
+++ b/ingestion/src/metadata/ingestion/source/trino.py
@@ -104,7 +104,7 @@ class TrinoSource(SQLSource):
                 schema_fqdn = get_fqdn(
                     DatabaseSchema,
                     self.config.serviceName,
-                    self.service_connection.database,
+                    self.service_connection.catalog,
                     schema,
                 )
                 yield from self.delete_tables(schema_fqdn)