apache#2450 fix spelling error and better variable name

Yangxuhao123 · Mar 12, 2024 · 9e393d8 · 9e393d8
1 parent c7767ed
commit 9e393d8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/integration-test/src/test/java/com/datastrato/gravitino/integration/test/spark/SparkIT.java b/integration-test/src/test/java/com/datastrato/gravitino/integration/test/spark/SparkIT.java
@@ -307,14 +307,14 @@ void testAlterTableRenameColumn() {
     checkTableColumns(tableName, simpleTableColumns, getTableInfo(tableName));
 
     String oldColumnName = "age";
-    String newColumnName = "newAge";
+    String newColumnName = "new_age";
 
     sql(
         String.format(
             "ALTER TABLE %S RENAME COLUMNS %S TO %S", tableName, oldColumnName, newColumnName));
     ArrayList<SparkColumnInfo> renameColumns = new ArrayList<>(simpleTableColumns);
-    renameColumns.remove(SparkColumnInfo.of("age", DataTypes.IntegerType, null));
-    renameColumns.add(SparkColumnInfo.of("newAge", DataTypes.IntegerType, null));
+    renameColumns.remove(SparkColumnInfo.of(oldColumnName, DataTypes.IntegerType, null));
+    renameColumns.add(SparkColumnInfo.of(newColumnName, DataTypes.IntegerType, null));
     checkTableColumns(tableName, renameColumns, getTableInfo(tableName));
   }
 

diff --git a/.../test/java/com/datastrato/gravitino/spark/connector/catalog/TestTransformTableChange.java b/.../test/java/com/datastrato/gravitino/spark/connector/catalog/TestTransformTableChange.java
@@ -54,7 +54,7 @@ void testTransformRenameColumn() {
     com.datastrato.gravitino.rel.TableChange.RenameColumn gravitinoRenameColumn =
         (com.datastrato.gravitino.rel.TableChange.RenameColumn) gravitinoChange;
 
-    Assertions.assertEquals(oldFiledsName, gravitinoRenameCeolumn.getFieldName());
+    Assertions.assertEquals(oldFiledsName, gravitinoRenameColumn.getFieldName());
     Assertions.assertEquals(newFiledName, gravitinoRenameColumn.getNewName());
   }