This is an automated email from the ASF dual-hosted git repository.
yuanfeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
The following commit(s) were added to refs/heads/master by this push:
new b5f637213 [hotfix] Fix incorrect parameter naming of some
`TableExecutor` (#3342)
b5f637213 is described below
commit b5f6372132bfdd730386f924c14e7d45bba670b1
Author: big face cat <[email protected]>
AuthorDate: Fri Nov 22 21:14:09 2024 +0800
[hotfix] Fix incorrect parameter naming of some `TableExecutor` (#3342)
Co-authored-by: huyuanfeng <[email protected]>
---
.../apache/amoro/server/table/executor/HiveCommitSyncExecutor.java | 4 ++--
.../apache/amoro/server/table/executor/OptimizingCommitExecutor.java | 4 ++--
.../amoro/server/table/executor/OptimizingExpiringExecutor.java | 4 ++--
.../amoro/server/table/executor/OrphanFilesCleaningExecutor.java | 4 ++--
.../apache/amoro/server/table/executor/SnapshotsExpiringExecutor.java | 4 ++--
.../amoro/server/table/executor/TableRuntimeRefreshExecutor.java | 4 ++--
6 files changed, 12 insertions(+), 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
index 504641ad8..6ea1a97d8 100644
---
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
index 2601c4ad4..29eb805d4 100644
---
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/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingExpiringExecutor.java
b/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingExpiringExecutor.java
index 06fbd91ab..f1be24eb4 100644
---
a/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OptimizingExpiringExecutor.java
+++
b/amoro-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/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OrphanFilesCleaningExecutor.java
b/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OrphanFilesCleaningExecutor.java
index 6d6cf01dc..6730d1221 100644
---
a/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/OrphanFilesCleaningExecutor.java
+++
b/amoro-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/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/SnapshotsExpiringExecutor.java
b/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/SnapshotsExpiringExecutor.java
index 04c2e1251..40ab0a85f 100644
---
a/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/SnapshotsExpiringExecutor.java
+++
b/amoro-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/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/TableRuntimeRefreshExecutor.java
b/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/TableRuntimeRefreshExecutor.java
index a83554d25..434c6ec83 100644
---
a/amoro-ams/src/main/java/org/apache/amoro/server/table/executor/TableRuntimeRefreshExecutor.java
+++
b/amoro-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;
}
