diff --git a/dask_planner/src/sql.rs b/dask_planner/src/sql.rs
index 48c27de02..719e08e3b 100644
--- a/dask_planner/src/sql.rs
+++ b/dask_planner/src/sql.rs
@@ -84,7 +84,14 @@ impl ContextProvider for DaskSQLContext {
     ) -> Result<Arc<dyn TableSource>, DataFusionError> {
         let reference: ResolvedTableReference =
             name.resolve(&self.default_catalog_name, &self.default_schema_name);
-        match self.schemas.get(&self.default_schema_name) {
+        if reference.catalog != self.default_catalog_name {
+            // there is a single catalog in Dask SQL
+            return Err(DataFusionError::Plan(format!(
+                "Cannot resolve catalog '{}'",
+                reference.catalog
+            )));
+        }
+        match self.schemas.get(reference.schema) {
             Some(schema) => {
                 let mut resp = None;
                 for table in schema.tables.values() {