From 4691abda291cf673b39368a28e4e037d977da9f7 Mon Sep 17 00:00:00 2001
From: zhangliang <zhangliang@apache.org>
Date: Thu, 24 Oct 2024 17:28:20 +0800
Subject: [PATCH] Remove useless PipelineTask.close()

---
 .../data/pipeline/core/task/TaskExecuteCallback.java             | 1 -
 1 file changed, 1 deletion(-)

diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/TaskExecuteCallback.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/TaskExecuteCallback.java
index 280c7345f10be..e89e41ba13b0d 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/TaskExecuteCallback.java
+++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/TaskExecuteCallback.java
@@ -39,6 +39,5 @@ public void onSuccess() {
     public void onFailure(final Throwable throwable) {
         log.error("onFailure, task ID={}", task.getTaskId(), throwable);
         task.stop();
-        IOUtils.closeQuietly(task);
     }
 }