diff --git a/chunjun-clients/src/main/java/com/dtstack/chunjun/client/yarn/YarnSessionClusterClientHelper.java b/chunjun-clients/src/main/java/com/dtstack/chunjun/client/yarn/YarnSessionClusterClientHelper.java index 80c526fd84..f45b697836 100644 --- a/chunjun-clients/src/main/java/com/dtstack/chunjun/client/yarn/YarnSessionClusterClientHelper.java +++ b/chunjun-clients/src/main/java/com/dtstack/chunjun/client/yarn/YarnSessionClusterClientHelper.java @@ -104,6 +104,9 @@ public ClusterClient submit(JobDeployer jobDeployer) throws Exception { 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;