Improve isAllInventoryTasksCompleted when all inventory task is empty (…

…#28912)
apache · Nov 2, 2023 · d9cf295 · d9cf295
1 parent 6a410d1
commit d9cf295
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...rg/apache/shardingsphere/data/pipeline/core/job/progress/PipelineJobProgressDetector.java b/...rg/apache/shardingsphere/data/pipeline/core/job/progress/PipelineJobProgressDetector.java
@@ -63,6 +63,9 @@ private static boolean isAllProgressesFilled(final int jobShardingCount, final C
     }
 
     private static boolean isAllInventoryTasksCompleted(final Collection<InventoryIncrementalJobItemProgress> jobItemProgresses) {
+        if (jobItemProgresses.stream().allMatch(each -> each.getInventory().getProgresses().isEmpty())) {
+            return false;
+        }
         return jobItemProgresses.stream().flatMap(each -> each.getInventory().getProgresses().values().stream()).allMatch(each -> each.getPosition() instanceof FinishedPosition);
     }
 }