Skip to content

Commit 316b29c

Browse files
pajakswendigo
authored andcommitted
Throw TrinoException in case of not found catalog
1 parent 79768d3 commit 316b29c

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

core/trino-main/src/main/java/io/trino/connector/StaticCatalogManager.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@
5454
import static com.google.common.collect.ImmutableList.toImmutableList;
5555
import static io.airlift.configuration.ConfigurationLoader.loadPropertiesFrom;
5656
import static io.trino.spi.StandardErrorCode.CATALOG_NOT_AVAILABLE;
57+
import static io.trino.spi.StandardErrorCode.CATALOG_NOT_FOUND;
5758
import static io.trino.spi.StandardErrorCode.NOT_SUPPORTED;
5859
import static io.trino.spi.connector.CatalogHandle.createRootCatalogHandle;
5960
import static io.trino.util.Executors.executeUntilFailure;
@@ -214,7 +215,9 @@ public Set<CatalogHandle> getActiveCatalogs()
214215
public ConnectorServices getConnectorServices(CatalogHandle catalogHandle)
215216
{
216217
CatalogConnector catalogConnector = catalogs.get(catalogHandle.getCatalogName());
217-
checkArgument(catalogConnector != null, "No catalog '%s'", catalogHandle.getCatalogName());
218+
if (catalogConnector == null) {
219+
throw new TrinoException(CATALOG_NOT_FOUND, "No catalog '%s'".formatted(catalogHandle.getCatalogName()));
220+
}
218221
return catalogConnector.getMaterializedConnector(catalogHandle.getType());
219222
}
220223

0 commit comments

Comments
 (0)