From b6783d999e920e833151f1225406931145a7c693 Mon Sep 17 00:00:00 2001 From: Kousuke Saruta Date: Tue, 19 May 2026 17:05:18 +0900 Subject: [PATCH 1/2] Add missing delegation methods to DelegatingCatalogExtension --- .../catalog/DelegatingCatalogExtension.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java index 786821514822e..9174bf822a59e 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java @@ -111,6 +111,19 @@ public Table createTable( return asTableCatalog().createTable(ident, columns, partitions, properties); } + @Override + public Table createTable(Identifier ident, TableInfo tableInfo) + throws TableAlreadyExistsException, NoSuchNamespaceException { + return asTableCatalog().createTable(ident, tableInfo); + } + + @Override + public Table createTableLike( + Identifier ident, TableInfo tableInfo, Table sourceTable) + throws TableAlreadyExistsException, NoSuchNamespaceException { + return asTableCatalog().createTableLike(ident, tableInfo, sourceTable); + } + @Override public Table alterTable( Identifier ident, From c1c5d49a340cbca991ae3d493ea90bf602f273ec Mon Sep 17 00:00:00 2001 From: Kousuke Saruta Date: Tue, 19 May 2026 19:43:43 +0900 Subject: [PATCH 2/2] Remove createTable(Identifier, TableInfo) delegation The default implementation in TableCatalog already falls back to createTable(ident, columns, partitions, properties), which is delegated. Explicitly delegating createTable(TableInfo) bypasses subclass overrides of createTable(Column[]). --- .../sql/connector/catalog/DelegatingCatalogExtension.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java index 9174bf822a59e..421785568bb71 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java @@ -111,12 +111,6 @@ public Table createTable( return asTableCatalog().createTable(ident, columns, partitions, properties); } - @Override - public Table createTable(Identifier ident, TableInfo tableInfo) - throws TableAlreadyExistsException, NoSuchNamespaceException { - return asTableCatalog().createTable(ident, tableInfo); - } - @Override public Table createTableLike( Identifier ident, TableInfo tableInfo, Table sourceTable)