(shardingsphere) branch master updated: Improve isAllInventoryTasksCompleted when all inventory task is empty (#28912)

[zhonghongsheng]

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

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new d9cf295e2b8 Improve isAllInventoryTasksCompleted when all inventory 
task is empty (#28912)
d9cf295e2b8 is described below

commit d9cf295e2b83c811d6568801a7d418018d9ca182
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Thu Nov 2 10:04:41 2023 +0800

    Improve isAllInventoryTasksCompleted when all inventory task is empty 
(#28912)
---
 .../data/pipeline/core/job/progress/PipelineJobProgressDetector.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/PipelineJobProgressDetector.java
 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/PipelineJobProgressDetector.java
index 36f8cf3b46e..ae07dba0ecb 100644
--- 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/PipelineJobProgressDetector.java
+++ 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/PipelineJobProgressDetector.java
@@ -63,6 +63,9 @@ public final class PipelineJobProgressDetector {
     }
     
     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);
     }
 }