Fix

apache · Sep 24, 2024 · 49f9ac3 · 49f9ac3
1 parent 3c21686
commit 49f9ac3
Showing 1 changed file with 17 additions and 9 deletions.
diff --git a/...a/org/apache/gravitino/catalog/lakehouse/paimon/integration/test/CatalogPaimonBaseIT.java b/...a/org/apache/gravitino/catalog/lakehouse/paimon/integration/test/CatalogPaimonBaseIT.java
@@ -891,15 +891,23 @@ private void createCatalog() {
     // Why needs this conversion? Because PaimonCatalogOperations#initialize will try to convert
     // Gravitino general S3 properties to Paimon specific S3 properties.
     Map<String, String> copy = Maps.newHashMap(catalogProperties);
-    copy.put(
-        PaimonCatalogPropertiesMetadata.S3_ENDPOINT,
-        catalogProperties.get(S3Properties.GRAVITINO_S3_ENDPOINT));
-    copy.put(
-        PaimonCatalogPropertiesMetadata.S3_ACCESS_KEY,
-        catalogProperties.get(S3Properties.GRAVITINO_S3_ACCESS_KEY_ID));
-    copy.put(
-        PaimonCatalogPropertiesMetadata.S3_SECRET_KEY,
-        catalogProperties.get(S3Properties.GRAVITINO_S3_SECRET_ACCESS_KEY));
+    if (catalogProperties.containsKey(S3Properties.GRAVITINO_S3_ENDPOINT)) {
+      copy.put(
+          PaimonCatalogPropertiesMetadata.S3_ENDPOINT,
+          catalogProperties.get(S3Properties.GRAVITINO_S3_ENDPOINT));
+    }
+
+    if (catalogProperties.containsKey(S3Properties.GRAVITINO_S3_ACCESS_KEY_ID)) {
+      copy.put(
+          PaimonCatalogPropertiesMetadata.S3_ACCESS_KEY,
+          catalogProperties.get(S3Properties.GRAVITINO_S3_ACCESS_KEY_ID));
+    }
+
+    if (catalogProperties.containsKey(S3Properties.GRAVITINO_S3_SECRET_ACCESS_KEY)) {
+      copy.put(
+          PaimonCatalogPropertiesMetadata.S3_SECRET_KEY,
+          catalogProperties.get(S3Properties.GRAVITINO_S3_SECRET_ACCESS_KEY));
+    }
 
     PaimonBackendCatalogWrapper paimonBackendCatalogWrapper =
         CatalogUtils.loadCatalogBackend(new PaimonConfig(copy));