[hotfix] Fix incorrect parameter naming of some TableExecutor (#3342)

Co-authored-by: huyuanfeng <huyuanfeng@huya.com>
apache · Nov 22, 2024 · b5f6372 · b5f6372
1 parent c12c240
commit b5f6372
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 12 deletions.
diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/HiveCommitSyncExecutor.java b/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/HiveCommitSyncExecutor.java
@@ -34,8 +34,8 @@ public class HiveCommitSyncExecutor extends BaseTableExecutor {
   // 10 minutes
   private static final long INTERVAL = 10 * 60 * 1000L;
 
-  public HiveCommitSyncExecutor(TableManager tableRuntimes, int poolSize) {
-    super(tableRuntimes, poolSize);
+  public HiveCommitSyncExecutor(TableManager tableManager, int poolSize) {
+    super(tableManager, poolSize);
   }
 
   @Override

diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingCommitExecutor.java b/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingCommitExecutor.java
@@ -29,8 +29,8 @@ public class OptimizingCommitExecutor extends BaseTableExecutor {
 
   private static final long INTERVAL = 60 * 1000L; // 1min
 
-  public OptimizingCommitExecutor(TableManager tableRuntimes, int poolSize) {
-    super(tableRuntimes, poolSize);
+  public OptimizingCommitExecutor(TableManager tableManager, int poolSize) {
+    super(tableManager, poolSize);
   }
 
   @Override

diff --git a/...-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingExpiringExecutor.java b/...-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingExpiringExecutor.java
@@ -32,8 +32,8 @@ public class OptimizingExpiringExecutor extends BaseTableExecutor {
   private final long keepTime;
   private final long interval;
 
-  public OptimizingExpiringExecutor(TableManager tableRuntimes, int keepDays, int intervalHours) {
-    super(tableRuntimes, 1);
+  public OptimizingExpiringExecutor(TableManager tableManager, int keepDays, int intervalHours) {
+    super(tableManager, 1);
     this.keepTime = keepDays * 24 * 60 * 60 * 1000L;
     this.interval = intervalHours * 60 * 60 * 1000L;
   }

diff --git a/...ams/src/main/java/org/apache/amoro/server/table/executor/OrphanFilesCleaningExecutor.java b/...ams/src/main/java/org/apache/amoro/server/table/executor/OrphanFilesCleaningExecutor.java
@@ -32,8 +32,8 @@ public class OrphanFilesCleaningExecutor extends BaseTableExecutor {
   private static final Logger LOG = LoggerFactory.getLogger(OrphanFilesCleaningExecutor.class);
   private final Duration interval;
 
-  public OrphanFilesCleaningExecutor(TableManager tableRuntimes, int poolSize, Duration interval) {
-    super(tableRuntimes, poolSize);
+  public OrphanFilesCleaningExecutor(TableManager tableManager, int poolSize, Duration interval) {
+    super(tableManager, poolSize);
     this.interval = interval;
   }
 

diff --git a/...o-ams/src/main/java/org/apache/amoro/server/table/executor/SnapshotsExpiringExecutor.java b/...o-ams/src/main/java/org/apache/amoro/server/table/executor/SnapshotsExpiringExecutor.java
@@ -32,8 +32,8 @@ public class SnapshotsExpiringExecutor extends BaseTableExecutor {
 
   private static final long INTERVAL = 60 * 60 * 1000L; // 1 hour
 
-  public SnapshotsExpiringExecutor(TableManager tableRuntimes, int poolSize) {
-    super(tableRuntimes, poolSize);
+  public SnapshotsExpiringExecutor(TableManager tableManager, int poolSize) {
+    super(tableManager, poolSize);
   }
 
   @Override

diff --git a/...ams/src/main/java/org/apache/amoro/server/table/executor/TableRuntimeRefreshExecutor.java b/...ams/src/main/java/org/apache/amoro/server/table/executor/TableRuntimeRefreshExecutor.java
@@ -36,8 +36,8 @@ public class TableRuntimeRefreshExecutor extends BaseTableExecutor {
   private final int maxPendingPartitions;
 
   public TableRuntimeRefreshExecutor(
-      TableManager tableRuntimes, int poolSize, long interval, int maxPendingPartitions) {
-    super(tableRuntimes, poolSize);
+      TableManager tableManager, int poolSize, long interval, int maxPendingPartitions) {
+    super(tableManager, poolSize);
     this.interval = interval;
     this.maxPendingPartitions = maxPendingPartitions;
   }