Fix and review

apache · Oct 25, 2024 · 2f5f127 · 2f5f127
1 parent 5a5c8ee
commit 2f5f127
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/.../flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java b/.../flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java
@@ -196,26 +196,26 @@ TriggerEvaluator evaluator() {
   DataStream<TaskResult> append(
       DataStream<Trigger> sourceStream,
       int taskIndex,
-      String taskName,
-      String tableName,
+      String newTaskName,
+      String newTableName,
       TableLoader newTableLoader,
       String defaultUidSuffix,
       String defaultSlotSharingGroup,
-      int mainParallelism) {
-    Preconditions.checkNotNull(taskName, "Task name should not be null");
+      int defaultParallelism) {
+    Preconditions.checkNotNull(newTaskName, "Task name should not be null");
     Preconditions.checkNotNull(newTableLoader, "TableLoader should not be null");
 
     this.index = taskIndex;
-    this.taskName = taskName;
-    this.tableName = tableName;
+    this.taskName = newTaskName;
+    this.tableName = newTableName;
     this.tableLoader = newTableLoader;
 
     if (uidSuffix == null) {
       uidSuffix = this.taskName + "_" + index + "_" + defaultUidSuffix;
     }
 
     if (parallelism == null) {
-      parallelism = mainParallelism;
+      parallelism = defaultParallelism;
     }
 
     if (slotSharingGroup == null) {