[fix] Change method name

apache · Nov 12, 2024 · bab3048 · bab3048
1 parent 592e119
commit bab3048
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
@@ -598,7 +598,7 @@ private List<SchemaChange> toSchemaChange(
             if (!oldTableNonPhysicalColumnIndex.containsKey(
                     ((ModifyPhysicalColumnType) change).getOldColumn().getName())) {
                 ModifyPhysicalColumnType modify = (ModifyPhysicalColumnType) change;
-                generatedNestedColumnUpdates(
+                generateNestedColumnUpdates(
                         Collections.singletonList(modify.getOldColumn().getName()),
                         LogicalTypeConversion.toDataType(
                                 modify.getOldColumn().getDataType().getLogicalType()),
@@ -668,7 +668,7 @@ && handleMaterializedTableChange(change, schemaChanges)) {
         throw new UnsupportedOperationException("Change is not supported: " + change.getClass());
     }
 
-    private void generatedNestedColumnUpdates(
+    private void generateNestedColumnUpdates(
             List<String> fieldNames,
             org.apache.paimon.types.DataType oldType,
             org.apache.paimon.types.DataType newType,
@@ -747,7 +747,7 @@ private void generatedNestedColumnUpdates(
                                         fullFieldNames.toArray(new String[0]),
                                         field.description()));
                     }
-                    generatedNestedColumnUpdates(
+                    generateNestedColumnUpdates(
                             fullFieldNames, oldField.type(), field.type(), schemaChanges);
                 }
             }