Schema is not creating with s3 uri when using polaris rest catalog

[udaykaithi]

We are using Trino 455 and trying to create a schema and & tables with polaris rest catalog from Trino.

Issue:

Schema created from Trino, doesn't have s3 URI location causing table creation to fail. Looks like, Trino is specifying the namespace location at creation time. Otherwise, Polaris will always add the catalog base location to the namespace. Can we check if Trino is specifying location implicitly and fix it.

Describe schema

	info_name	info_value
0	Catalog Name	demo
1	Namespace Name	tpch1
2	Location	demo/tpch1
3	Properties	

In the above output, location doesn't have s3 uri like s3://bucket-name/. This is causing the table creation to fail with below error. Ideally, it should create with s3://bucket/plrs-warehouse/demo/tpch1

Table creation Query:

trino> CREATE OR REPLACE TABLE polaris.tpch1.table_4 (id bigint);

Error:

org.apache.iceberg.exceptions.RESTException: Unable to process: Failed to get subscoped credentials: Invalid S3 URI: no hostname: demo/tpch1/table_4-6faf13a274c74e44820762ee62e9be0d

Even creating schema with correct location is also failing with below error

trino> CREATE SCHEMA polaris.tpch1 WITH (location = 's3://bucket/plrs-warehouse/demo/tpch1');
Query 20250205_215646_00035_8qjqr failed: Multiple entries with same key: location=demo/tpch1 and location=s3://bucket/plrs-warehouse/demo/tpch1

Additional details:

Catalog Info:

{
            "type": "INTERNAL",
            "name": "demo",
            "properties": {
                "default-base-location": "s3://bucket/plrs-warehouse/demo"
            },
            "createTimestamp": 1737505711042,
            "lastUpdateTimestamp": 1737505711042,
            "entityVersion": 1,
            "storageConfigInfo": {
                "storageType": "S3",
                "roleArn": "arn:aws:iam::xxxxxxx:role/role-name",
                "externalId": null,
                "userArn": null,
                "region": null,
                "deriveKMSResources": true,
                "allowedLocations": [
                    "s3://bucket/plrs-warehouse/demo"
                ]
            }
        },

connector info:

                connector.name=iceberg
                iceberg.catalog.type=rest
                iceberg.rest-catalog.uri=http://xxxxx:8181/api/catalog
                iceberg.rest-catalog.security=OAUTH2
                iceberg.rest-catalog.oauth2.credential=Clientid:clientSecret
                fs.native-s3.enabled=true
                iceberg.rest-catalog.warehouse=demo
                iceberg.rest-catalog.oauth2.scope=PRINCIPAL_ROLE:ALL
                iceberg.rest-catalog.vended-credentials-enabled=true

complete stacktrace:

Table creation error: (when schema is created without location)

org.apache.iceberg.exceptions.RESTException: Unable to process: Failed to get subscoped credentials: Invalid S3 URI: no hostname: demo/tpch1/table_4-6faf13a274c74e44820762ee62e9be0d
	at org.apache.iceberg.rest.ErrorHandlers$DefaultErrorHandler.accept(ErrorHandlers.java:224)
	at org.apache.iceberg.rest.ErrorHandlers$TableErrorHandler.accept(ErrorHandlers.java:118)
	at org.apache.iceberg.rest.ErrorHandlers$TableErrorHandler.accept(ErrorHandlers.java:102)
	at org.apache.iceberg.rest.HTTPClient.throwFailure(HTTPClient.java:201)
	at org.apache.iceberg.rest.HTTPClient.execute(HTTPClient.java:313)
	at org.apache.iceberg.rest.HTTPClient.execute(HTTPClient.java:252)
	at org.apache.iceberg.rest.HTTPClient.post(HTTPClient.java:358)
	at org.apache.iceberg.rest.RESTClient.post(RESTClient.java:112)
	at org.apache.iceberg.rest.RESTSessionCatalog$Builder.stageCreate(RESTSessionCatalog.java:825)
	at org.apache.iceberg.rest.RESTSessionCatalog$Builder.createTransaction(RESTSessionCatalog.java:708)
	at org.apache.iceberg.rest.RESTSessionCatalog$Builder.createOrReplaceTransaction(RESTSessionCatalog.java:807)
	at io.trino.plugin.iceberg.catalog.rest.TrinoRestCatalog.newCreateOrReplaceTableTransaction(TrinoRestCatalog.java:315)
	at io.trino.plugin.iceberg.IcebergUtil.newCreateTableTransaction(IcebergUtil.java:838)
	at io.trino.plugin.iceberg.IcebergMetadata.beginCreateTable(IcebergMetadata.java:1055)
	at io.trino.plugin.iceberg.IcebergMetadata.createTable(IcebergMetadata.java:950)
	at io.trino.plugin.base.classloader.ClassLoaderSafeConnectorMetadata.createTable(ClassLoaderSafeConnectorMetadata.java:498)
	at io.trino.tracing.TracingConnectorMetadata.createTable(TracingConnectorMetadata.java:440)
	at io.trino.metadata.MetadataManager.createTable(MetadataManager.java:837)
	at io.trino.tracing.TracingMetadata.createTable(TracingMetadata.java:410)
	at io.trino.execution.CreateTableTask.internalExecute(CreateTableTask.java:297)
	at io.trino.execution.CreateTableTask.execute(CreateTableTask.java:126)
	at io.trino.execution.CreateTableTask.execute(CreateTableTask.java:92)
	at io.trino.execution.DataDefinitionExecution.start(DataDefinitionExecution.java:146)
	at io.trino.execution.SqlQueryManager.createQuery(SqlQueryManager.java:272)
	at io.trino.dispatcher.LocalDispatchQuery.startExecution(LocalDispatchQuery.java:150)
	at io.trino.dispatcher.LocalDispatchQuery.lambda$waitForMinimumWorkers$2(LocalDispatchQuery.java:134)
	at io.airlift.concurrent.MoreFutures.lambda$addSuccessCallback$12(MoreFutures.java:570)
	at io.airlift.concurrent.MoreFutures$3.onSuccess(MoreFutures.java:545)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1137)

schema when creating with location error:

java.lang.IllegalArgumentException: Multiple entries with same key: location=demo/tpch2 and location=s3://<bcuket>/plrs-warehouse/demo/tpch2/
	at com.google.common.collect.ImmutableMap.conflictException(ImmutableMap.java:382)
	at com.google.common.collect.ImmutableMap.checkNoConflict(ImmutableMap.java:376)
	at com.google.common.collect.RegularImmutableMap.checkNoConflictInKeyBucket(RegularImmutableMap.java:249)
	at com.google.common.collect.RegularImmutableMap.fromEntryArrayCheckingBucketOverflow(RegularImmutableMap.java:136)
	at com.google.common.collect.RegularImmutableMap.fromEntryArray(RegularImmutableMap.java:98)
	at com.google.common.collect.ImmutableMap$Builder.build(ImmutableMap.java:579)
	at com.google.common.collect.ImmutableMap$Builder.buildOrThrow(ImmutableMap.java:607)
	at io.trino.plugin.iceberg.catalog.rest.TrinoRestCatalog.createNamespace(TrinoRestCatalog.java:187)
	at io.trino.plugin.iceberg.IcebergMetadata.createSchema(IcebergMetadata.java:914)
	at io.trino.plugin.base.classloader.ClassLoaderSafeConnectorMetadata.createSchema(ClassLoaderSafeConnectorMetadata.java:434)
	at io.trino.tracing.TracingConnectorMetadata.createSchema(TracingConnectorMetadata.java:394)
	at io.trino.metadata.MetadataManager.createSchema(MetadataManager.java:787)
	at io.trino.tracing.TracingMetadata.createSchema(TracingMetadata.java:374)
	at io.trino.execution.CreateSchemaTask.internalExecute(CreateSchemaTask.java:128)
	at io.trino.execution.CreateSchemaTask.execute(CreateSchemaTask.java:82)
	at io.trino.execution.CreateSchemaTask.execute(CreateSchemaTask.java:54)
	at io.trino.execution.DataDefinitionExecution.start(DataDefinitionExecution.java:146)
	at io.trino.execution.SqlQueryManager.createQuery(SqlQueryManager.java:272)
	at io.trino.dispatcher.LocalDispatchQuery.startExecution(LocalDispatchQuery.java:150)
	at io.trino.dispatcher.LocalDispatchQuery.lambda$waitForMinimumWorkers$2(LocalDispatchQuery.java:134)
	at io.airlift.concurrent.MoreFutures.lambda$addSuccessCallback$12(MoreFutures.java:570)
	at io.airlift.concurrent.MoreFutures$3.onSuccess(MoreFutures.java:545)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1137)