From f61a5356d67e2380badb872d998f086a8b1d10ee Mon Sep 17 00:00:00 2001 From: yangyang zhong <35210666+hdygxsj@users.noreply.github.com> Date: Fri, 10 Jan 2025 21:53:48 +0800 Subject: [PATCH] fix spark ci bug --- .../connector/paimon/PaimonPropertiesConverter.java | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/paimon/PaimonPropertiesConverter.java b/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/paimon/PaimonPropertiesConverter.java index f713ca89ddd..1544dfeec8c 100644 --- a/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/paimon/PaimonPropertiesConverter.java +++ b/spark-connector/spark-common/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 toSparkCatalogProperties(Map properties) { Preconditions.checkArgument(properties != null, "Paimon Catalog properties should not be null"); - Map 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