diff --git a/chunjun-clients/src/main/java/com/dtstack/chunjun/client/standalone/StandaloneClusterClientHelper.java b/chunjun-clients/src/main/java/com/dtstack/chunjun/client/standalone/StandaloneClusterClientHelper.java index 7dc72edde8..7a6f69f445 100644 --- a/chunjun-clients/src/main/java/com/dtstack/chunjun/client/standalone/StandaloneClusterClientHelper.java +++ b/chunjun-clients/src/main/java/com/dtstack/chunjun/client/standalone/StandaloneClusterClientHelper.java @@ -59,6 +59,9 @@ public ClusterClient submit(JobDeployer jobDeployer) throws Exception { .getClusterClient(); JobGraph jobGraph = JobGraphUtil.buildJobGraph(launcherOptions, programArgs.toArray(new String[0])); + jobGraph.getClasspaths().clear(); + jobGraph.getUserJars().clear(); + jobGraph.getUserArtifacts().clear(); JobID jobID = (JobID) clusterClient.submitJob(jobGraph).get(); LOG.info("submit job successfully, jobID = {}", jobID); return clusterClient;