diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractSimplePipelineJob.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractSimplePipelineJob.java
index fa3e33aab7532..91358b03a97ce 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractSimplePipelineJob.java
+++ b/kernel/data-pipeline/core/src/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;
         }
     }