(amoro) branch master updated: [AMORO-3269] Use actualPartitionPlans to determine the optimizingType (#3270)

[jinsongzhou]

This is an automated email from the ASF dual-hosted git repository.

jinsongzhou 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 bd2485a4b [AMORO-3269] Use actualPartitionPlans to determine the 
optimizingType (#3270)
bd2485a4b is described below

commit bd2485a4be5ef89a818fe96e60d74b758450c6e0
Author: 7hong <hon...@163.com>
AuthorDate: Thu Oct 17 14:19:01 2024 +0800

    [AMORO-3269] Use actualPartitionPlans to determine the optimizingType 
(#3270)
    
    Use actualPartitionPlans to determine the optimizingType
---
 .../apache/amoro/server/optimizing/plan/OptimizingPlanner.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/plan/OptimizingPlanner.java
 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/plan/OptimizingPlanner.java
index c87a66c8a..cf6fc9e71 100644
--- 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/plan/OptimizingPlanner.java
+++ 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/plan/OptimizingPlanner.java
@@ -175,11 +175,11 @@ public class OptimizingPlanner extends 
OptimizingEvaluator {
       tasks.addAll(partitionPlan.splitTasks((int) (actualInputSize / 
avgThreadCost)));
     }
     if (!tasks.isEmpty()) {
-      if (evaluators.stream()
-          .anyMatch(evaluator -> evaluator.getOptimizingType() == 
OptimizingType.FULL)) {
+      if (actualPartitionPlans.stream()
+          .anyMatch(plan -> plan.getOptimizingType() == OptimizingType.FULL)) {
         optimizingType = OptimizingType.FULL;
-      } else if (evaluators.stream()
-          .anyMatch(evaluator -> evaluator.getOptimizingType() == 
OptimizingType.MAJOR)) {
+      } else if (actualPartitionPlans.stream()
+          .anyMatch(plan -> plan.getOptimizingType() == OptimizingType.MAJOR)) 
{
         optimizingType = OptimizingType.MAJOR;
       } else {
         optimizingType = OptimizingType.MINOR;