1

liugddx · Jan 1, 2024 · ff5eb5c · ff5eb5c
1 parent d48de42
commit ff5eb5c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/...el-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java b/...el-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
@@ -442,6 +442,7 @@ public PassiveCompletableFuture<Void> submitJob(long jobId, Data jobImmutableInf
                         runningJobInfoIMap.remove(jobId);
                         runningJobMasterMap.remove(jobId);
                     }
+                    jobMaster.setClassLoader(null);
                 });
         return new PassiveCompletableFuture<>(jobSubmitFuture);
     }

diff --git a/...nnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java b/...nnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java
@@ -448,6 +448,10 @@ public ClassLoader getClassLoader() {
         return classLoader;
     }
 
+    public void setClassLoader(ClassLoader classLoader) {
+        this.classLoader = classLoader;
+    }
+
     public void cancelJob() {
         physicalPlan.cancelJob();
     }