Add PipelineJobItemManager

apache · Nov 18, 2023 · d15158f · d15158f
1 parent 3ba58fe
commit d15158f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...ain/java/org/apache/shardingsphere/data/pipeline/core/job/service/PipelineJobManager.java b/...ain/java/org/apache/shardingsphere/data/pipeline/core/job/service/PipelineJobManager.java
@@ -54,8 +54,6 @@ public final class PipelineJobManager {
 
     private final PipelineJobAPI jobAPI;
 
-    private final PipelineJobItemManager<? extends PipelineJobItemProgress> jobItemManager = new PipelineJobItemManager<>(jobAPI.getYamlJobItemProgressSwapper());
-
     /**
      * Get job configuration.
      *
@@ -93,7 +91,7 @@ public Optional<String> start(final PipelineJobConfiguration jobConfig) {
      */
     public void startDisabledJob(final String jobId) {
         if (jobAPI.isIgnoreToStartDisabledJobWhenJobItemProgressIsFinished()) {
-            Optional<? extends PipelineJobItemProgress> jobItemProgress = jobItemManager.getProgress(jobId, 0);
+            Optional<? extends PipelineJobItemProgress> jobItemProgress = new PipelineJobItemManager<>(jobAPI.getYamlJobItemProgressSwapper()).getProgress(jobId, 0);
             if (jobItemProgress.isPresent() && JobStatus.FINISHED == jobItemProgress.get().getStatus()) {
                 log.info("job status is FINISHED, ignore, jobId={}", jobId);
                 return;