Skip to content

Commit 7330b17

Browse files
author
zhangyongxiang.alpha
committed
fix ActionCoordinatorScheduler
1 parent 3fe4764 commit 7330b17

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

amoro-ams/src/main/java/org/apache/amoro/server/process/ActionCoordinatorScheduler.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,14 +41,12 @@ public class ActionCoordinatorScheduler extends PeriodicTableScheduler {
4141

4242
private final ActionCoordinator coordinator;
4343
private final ProcessService processService;
44-
private final long intervalMillis;
4544

4645
public ActionCoordinatorScheduler(
4746
ActionCoordinator coordinator, TableService tableService, ProcessService processService) {
4847
super(coordinator.action(), tableService, coordinator.parallelism());
4948
this.coordinator = coordinator;
5049
this.processService = processService;
51-
this.intervalMillis = coordinator.getExecutorDelay();
5250
}
5351

5452
/**

0 commit comments

Comments
 (0)