1

seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java

@@ -68,6 +68,7 @@
 
 import java.io.IOException;
 import java.net.URL;
+import java.net.URLClassLoader;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
@@ -265,11 +266,13 @@ public TaskDeployState deployTask(@NonNull TaskGroupImmutableInformation taskImm
                         "received deploying task executionId [%s]",
                         taskImmutableInfo.getExecutionId()));
         TaskGroup taskGroup = null;
+        URLClassLoader classLoader =
+                (URLClassLoader) Thread.currentThread().getContextClassLoader();
+
         try {
             Set<ConnectorJarIdentifier> connectorJarIdentifiers =
                     taskImmutableInfo.getConnectorJarIdentifiers();
             Set<URL> jars = taskImmutableInfo.getJars();
-            ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
             if (!CollectionUtils.isEmpty(connectorJarIdentifiers)) {
                 // Prioritize obtaining the jar package file required for the current task execution
                 // from the local, if it does not exist locally, it will be downloaded from the
@@ -319,6 +322,17 @@ public TaskDeployState deployTask(@NonNull TaskGroupImmutableInformation taskImm
                                     : "taskGroupLocation is null",
                             ExceptionUtils.getMessage(t)));
             return TaskDeployState.failed(t);
+        } finally {
+            if (classLoader != null) {
+                try {
+                    classLoader.close();
+                } catch (IOException e) {
+                    logger.severe(
+                            String.format(
+                                    "Close classLoader error with Exception: %s",
+                                    ExceptionUtils.getMessage(e)));
+                }
+            }
         }
     }