fix

apache · Dec 24, 2024 · ff12574 · ff12574
1 parent 59c9456
commit ff12574
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 8 deletions.
diff --git a/...ouse-paimon/src/main/java/org/apache/gravitino/catalog/lakehouse/paimon/PaimonSchema.java b/...ouse-paimon/src/main/java/org/apache/gravitino/catalog/lakehouse/paimon/PaimonSchema.java
@@ -20,8 +20,6 @@
 
 import static org.apache.gravitino.meta.AuditInfo.EMPTY;
 
-import com.google.common.collect.Maps;
-import java.util.HashMap;
 import java.util.Map;
 import java.util.Optional;
 import lombok.ToString;
@@ -81,18 +79,15 @@ protected PaimonSchema internalBuild() {
       PaimonSchema paimonSchema = new PaimonSchema();
       paimonSchema.name = name;
 
-      Map<String, String> propertiesWithComment =
-          Maps.newHashMap(Optional.ofNullable(properties).orElse(new HashMap<>()));
       if (comment != null) {
         paimonSchema.comment = comment;
-        propertiesWithComment.put(PaimonSchemaPropertiesMetadata.COMMENT, comment);
       } else if (properties != null) {
         paimonSchema.comment = properties.get(PaimonSchemaPropertiesMetadata.COMMENT);
       } else {
         paimonSchema.comment = null;
       }
 
-      paimonSchema.properties = propertiesWithComment;
+      paimonSchema.properties = properties;
       paimonSchema.auditInfo = auditInfo;
       return paimonSchema;
     }

diff --git a/.../gravitino/spark/connector/integration/test/paimon/SparkPaimonCatalogHiveBackendIT35.java b/.../gravitino/spark/connector/integration/test/paimon/SparkPaimonCatalogHiveBackendIT35.java
@@ -18,7 +18,7 @@
  */
 package org.apache.gravitino.spark.connector.integration.test.paimon;
 
-import org.apache.gravitino.spark.connector.iceberg.GravitinoIcebergCatalogSpark35;
+import org.apache.gravitino.spark.connector.paimon.GravitinoPaimonCatalogSpark35;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
@@ -28,6 +28,6 @@ public class SparkPaimonCatalogHiveBackendIT35 extends SparkPaimonCatalogHiveBac
   void testCatalogClassName() {
     String catalogClass =
         getSparkSession().sparkContext().conf().get("spark.sql.catalog." + getCatalogName());
-    Assertions.assertEquals(GravitinoIcebergCatalogSpark35.class.getName(), catalogClass);
+    Assertions.assertEquals(GravitinoPaimonCatalogSpark35.class.getName(), catalogClass);
   }
 }