(polaris) branch main updated: CatalogEntity: internal endpoint not considered (#2292)

[snazy]

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";);
     }