fix spark ci bug

apache · Jan 10, 2025 · f61a535 · f61a535
1 parent 16fb66b
commit f61a535
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/.../src/main/java/org/apache/gravitino/spark/connector/paimon/PaimonPropertiesConverter.java b/.../src/main/java/org/apache/gravitino/spark/connector/paimon/PaimonPropertiesConverter.java
@@ -22,7 +22,6 @@
 import com.google.common.base.Preconditions;
 import java.util.HashMap;
 import java.util.Map;
-import org.apache.commons.lang3.StringUtils;
 import org.apache.gravitino.catalog.lakehouse.paimon.PaimonConstants;
 import org.apache.gravitino.catalog.lakehouse.paimon.PaimonPropertiesUtils;
 import org.apache.gravitino.spark.connector.PropertiesConverter;
@@ -42,14 +41,7 @@ public static PaimonPropertiesConverter getInstance() {
   @Override
   public Map<String, String> toSparkCatalogProperties(Map<String, String> properties) {
     Preconditions.checkArgument(properties != null, "Paimon Catalog properties should not be null");
-    Map<String, String> all = PaimonPropertiesUtils.toPaimonCatalogProperties(properties);
-    String catalogBackend = all.remove(PaimonPropertiesConstants.GRAVITINO_PAIMON_CATALOG_BACKEND);
-    Preconditions.checkArgument(
-        StringUtils.isNotBlank(catalogBackend),
-        String.format(
-            "%s should not be empty", PaimonPropertiesConstants.GRAVITINO_PAIMON_CATALOG_BACKEND));
-    all.put(PaimonPropertiesConstants.PAIMON_CATALOG_METASTORE, catalogBackend);
-    return all;
+    return PaimonPropertiesUtils.toPaimonCatalogProperties(properties);
   }
 
   @Override