[apache#2447] feat(spark-connector): support alter table AddColumn an…

…d DropColumn for spark-connector
caican00 · Mar 7, 2024 · 612d59f · 612d59f
1 parent c5317d4
commit 612d59f
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/.../test/java/com/datastrato/gravitino/spark/connector/catalog/TestTransformTableChange.java b/.../test/java/com/datastrato/gravitino/spark/connector/catalog/TestTransformTableChange.java
@@ -49,8 +49,6 @@ void testTransformAddColumn() {
     com.datastrato.gravitino.rel.TableChange.AddColumn gravitinoAddColumn =
         (com.datastrato.gravitino.rel.TableChange.AddColumn) gravitinoChange;
 
-    Assertions.assertEquals(1, sparkAddColumn.fieldNames().length);
-    Assertions.assertEquals(1, gravitinoAddColumn.fieldName().length);
     Assertions.assertEquals(sparkAddColumn.fieldNames(), gravitinoAddColumn.fieldName());
     Assertions.assertTrue(
         "string".equalsIgnoreCase(gravitinoAddColumn.getDataType().simpleString()));
@@ -68,8 +66,6 @@ void testTransformDeleteColumn() {
     com.datastrato.gravitino.rel.TableChange.DeleteColumn gravitinoDeleteColumn =
         (com.datastrato.gravitino.rel.TableChange.DeleteColumn) gravitinoChange;
 
-    Assertions.assertEquals(1, sparkDeleteColumn.fieldNames().length);
-    Assertions.assertEquals(1, gravitinoDeleteColumn.fieldName().length);
     Assertions.assertEquals(sparkDeleteColumn.fieldNames(), gravitinoDeleteColumn.fieldName());
     Assertions.assertEquals(sparkDeleteColumn.ifExists(), gravitinoDeleteColumn.getIfExists());
   }