Pass internal properties to FileIO

apache · Jan 10, 2025 · 057bd17 · 057bd17
1 parent 9809e0e
commit 057bd17
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/polaris-service/src/main/java/org/apache/polaris/service/catalog/BasePolarisCatalog.java b/polaris-service/src/main/java/org/apache/polaris/service/catalog/BasePolarisCatalog.java
@@ -1612,6 +1612,12 @@ private FileIO refreshIOWithCredentials(
     // the credentials should always override table-level properties, since
     // storage configuration will be found at whatever entity defines it
     tableProperties.putAll(credentialsMap);
+
+    // Populate the internal properties to FileIO in case the FileIO implementation needs them
+    Map<String, String> internalProperties =
+        storageInfoEntity.map(PolarisEntity::getInternalPropertiesAsMap).orElse(Map.of());
+    tableProperties.putAll(internalProperties);
+
     FileIO fileIO = null;
     fileIO = loadFileIO(ioImplClassName, tableProperties);
     // ensure the new fileIO is closed when the catalog is closed