(shardingsphere) branch master updated: Refactor AbstractInseparablePipelineJob‘s job stopping judge (#32741)

[zhaojinchao]

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

zhaojinchao 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 e38011880a9 Refactor AbstractInseparablePipelineJob‘s job stopping 
judge (#32741)
e38011880a9 is described below

commit e38011880a9829e2f2eea156226e14907cf9d822
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sat Aug 31 14:14:12 2024 +0800

    Refactor AbstractInseparablePipelineJob‘s job stopping judge (#32741)
---
 .../data/pipeline/core/job/AbstractInseparablePipelineJob.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractInseparablePipelineJob.java
 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractInseparablePipelineJob.java
index 6f770eafe38..bfeb843e569 100644
--- 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractInseparablePipelineJob.java
+++ 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractInseparablePipelineJob.java
@@ -58,14 +58,14 @@ public abstract class AbstractInseparablePipelineJob<T 
extends PipelineJobConfig
     public final void execute(final ShardingContext shardingContext) {
         String jobId = shardingContext.getJobName();
         log.info("Execute job {}", jobId);
+        if (jobRunnerManager.isStopping()) {
+            log.info("Job is stopping, ignore.");
+            return;
+        }
         PipelineJobType jobType = PipelineJobIdUtils.parseJobType(jobId);
         T jobConfig = (T) 
jobType.getYamlJobConfigurationSwapper().swapToObject(shardingContext.getJobParameter());
         Collection<I> jobItemContexts = new LinkedList<>();
         for (int shardingItem = 0; shardingItem < 
jobConfig.getJobShardingCount(); shardingItem++) {
-            if (jobRunnerManager.isStopping()) {
-                log.info("Job is stopping, ignore.");
-                return;
-            }
             I jobItemContext = buildJobItemContext(jobConfig, shardingItem);
             if (!jobRunnerManager.addTasksRunner(shardingItem, 
buildTasksRunner(jobItemContext))) {
                 continue;