File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
amoro-ams/src/main/java/org/apache/amoro/server/scheduler/inline Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change 2424import org .apache .amoro .optimizing .plan .AbstractOptimizingEvaluator ;
2525import org .apache .amoro .process .ProcessStatus ;
2626import org .apache .amoro .server .optimizing .OptimizingProcess ;
27+ import org .apache .amoro .server .optimizing .OptimizingStatus ;
2728import org .apache .amoro .server .scheduler .PeriodicTableScheduler ;
2829import org .apache .amoro .server .table .DefaultTableRuntime ;
2930import org .apache .amoro .server .table .TableService ;
@@ -58,8 +59,9 @@ protected long getNextExecutingTime(TableRuntime tableRuntime) {
5859 }
5960
6061 private void tryEvaluatingPendingInput (DefaultTableRuntime tableRuntime , MixedTable table ) {
62+ // only evaluate pending input when optimizing is enabled and in idle state
6163 if (tableRuntime .getTableConfiguration ().getOptimizingConfig ().isEnabled ()
62- && ! tableRuntime .getOptimizingStatus ().isProcessing ( )) {
64+ && tableRuntime .getOptimizingStatus ().equals ( OptimizingStatus . IDLE )) {
6365 AbstractOptimizingEvaluator evaluator =
6466 IcebergTableUtil .createOptimizingEvaluator (tableRuntime , table , maxPendingPartitions );
6567 if (evaluator .isNecessary ()) {
You can’t perform that action at this time.
0 commit comments