Fix sonar issue

apache · Nov 25, 2023 · 6e25149 · 6e25149
1 parent 01329b1
commit 6e25149
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractSimplePipelineJob.java b/...main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractSimplePipelineJob.java
@@ -48,7 +48,6 @@ protected AbstractSimplePipelineJob(final String jobId) {
 
     @Override
     public void execute(final ShardingContext shardingContext) {
-        PipelineJobManager jobManager = new PipelineJobManager(getJobAPI());
         String jobId = shardingContext.getJobName();
         int shardingItem = shardingContext.getShardingItem();
         log.info("Execute job {}-{}", jobId, shardingItem);
@@ -62,7 +61,7 @@ public void execute(final ShardingContext shardingContext) {
             // CHECKSTYLE:OFF
         } catch (final RuntimeException ex) {
             // CHECKSTYLE:ON
-            processFailed(jobManager, jobId, shardingItem, ex);
+            processFailed(new PipelineJobManager(getJobAPI()), jobId, shardingItem, ex);
             throw ex;
         }
     }