This is an automated email from the ASF dual-hosted git repository. snazy pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/polaris.git
The following commit(s) were added to refs/heads/main by this push: new 2f985ab93 CatalogEntity: internal endpoint not considered (#2292) 2f985ab93 is described below commit 2f985ab93ccd65b0c98fdd8902e217792c622a68 Author: Robert Stupp <sn...@snazy.de> AuthorDate: Mon Aug 11 15:32:16 2025 +0200 CatalogEntity: internal endpoint not considered (#2292) Setting an S3 internal endpoint doesn't work, because the property's not carried over from the OpenAPI model type into `AwsStorageConfigInfo`. --- .../main/java/org/apache/polaris/core/entity/CatalogEntity.java | 1 + .../org/apache/polaris/service/it/RestCatalogMinIOSpecialIT.java | 9 +++++++++ 2 files changed, 10 insertions(+) diff --git a/polaris-core/src/main/java/org/apache/polaris/core/entity/CatalogEntity.java b/polaris-core/src/main/java/org/apache/polaris/core/entity/CatalogEntity.java index 622df1fca..a3343c7a0 100644 --- a/polaris-core/src/main/java/org/apache/polaris/core/entity/CatalogEntity.java +++ b/polaris-core/src/main/java/org/apache/polaris/core/entity/CatalogEntity.java @@ -141,6 +141,7 @@ public class CatalogEntity extends PolarisEntity implements LocationBasedEntity .setEndpoint(awsConfig.getEndpoint()) .setStsEndpoint(awsConfig.getStsEndpoint()) .setPathStyleAccess(awsConfig.getPathStyleAccess()) + .setEndpointInternal(awsConfig.getEndpointInternal()) .build(); } if (configInfo instanceof AzureStorageConfigurationInfo) { diff --git a/runtime/service/src/intTest/java/org/apache/polaris/service/it/RestCatalogMinIOSpecialIT.java b/runtime/service/src/intTest/java/org/apache/polaris/service/it/RestCatalogMinIOSpecialIT.java index 9d2f22be7..b4d171d1b 100644 --- a/runtime/service/src/intTest/java/org/apache/polaris/service/it/RestCatalogMinIOSpecialIT.java +++ b/runtime/service/src/intTest/java/org/apache/polaris/service/it/RestCatalogMinIOSpecialIT.java @@ -230,6 +230,15 @@ public class RestCatalogMinIOSpecialIT { Optional.of(endpoint), false, Optional.of(endpoint))) { + StorageConfigInfo storageConfig = + managementApi.getCatalog(catalogName).getStorageConfigInfo(); + assertThat((AwsStorageConfigInfo) storageConfig) + .extracting( + AwsStorageConfigInfo::getEndpoint, + AwsStorageConfigInfo::getStsEndpoint, + AwsStorageConfigInfo::getEndpointInternal, + AwsStorageConfigInfo::getPathStyleAccess) + .containsExactly("http://s3.example.com", endpoint, endpoint, false); LoadTableResponse loadTableResponse = doTestCreateTable(restCatalog); assertThat(loadTableResponse.config()).containsEntry("s3.endpoint", "http://s3.example.com"); }