Skip to content

Commit

Permalink
[hotfix] Fix incorrect parameter naming of some TableExecutor
Browse files Browse the repository at this point in the history
  • Loading branch information
huyuanfeng committed Nov 22, 2024
1 parent f88b7a6 commit b9a8c4f
Show file tree
Hide file tree
Showing 6 changed files with 12 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down

0 comments on commit b9a8c4f

Please sign in to comment.