fix class not found exception (apache#5063)

liunaijie · Jul 13, 2023 · 24e528a · 24e528a
1 parent 8cc3c0f
commit 24e528a
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/...er/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java b/...er/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java
@@ -22,6 +22,7 @@
 import org.apache.seatunnel.shade.com.fasterxml.jackson.databind.ObjectMapper;
 
 import org.apache.seatunnel.engine.common.Constant;
+import org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader;
 import org.apache.seatunnel.engine.core.dag.logical.LogicalDag;
 import org.apache.seatunnel.engine.core.job.JobImmutableInformation;
 import org.apache.seatunnel.engine.core.job.JobInfo;
@@ -42,6 +43,7 @@
 import com.hazelcast.internal.json.JsonValue;
 import com.hazelcast.internal.util.JsonUtil;
 import com.hazelcast.internal.util.StringUtil;
+import com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject;
 import com.hazelcast.map.IMap;
 import com.hazelcast.spi.impl.NodeEngine;
 
@@ -227,12 +229,14 @@ private JsonObject convertToJson(JobInfo jobInfo, long jobId) {
                                         .getNodeEngine()
                                         .getSerializationService()
                                         .toObject(jobInfo.getJobImmutableInformation()));
+
+        ClassLoader classLoader =
+                new SeaTunnelChildFirstClassLoader(jobImmutableInformation.getPluginJarsUrls());
         LogicalDag logicalDag =
-                this.textCommandService
-                        .getNode()
-                        .getNodeEngine()
-                        .getSerializationService()
-                        .toObject(jobImmutableInformation.getLogicalDag());
+                CustomClassLoadedObject.deserializeWithCustomClassLoader(
+                        this.textCommandService.getNode().getNodeEngine().getSerializationService(),
+                        classLoader,
+                        jobImmutableInformation.getLogicalDag());
 
         String jobMetrics =
                 getSeaTunnelServer().getCoordinatorService().getJobMetrics(jobId).toJsonString();