[FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils

flink-clients/src/main/java/org/apache/flink/client/deployment/executors/PipelineExecutorUtils.java

@@ -21,15 +21,13 @@
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.api.common.RuntimeExecutionMode;
 import org.apache.flink.api.dag.Pipeline;
-import org.apache.flink.client.FlinkPipelineTranslationUtil;
 import org.apache.flink.client.cli.ClientOptions;
 import org.apache.flink.client.cli.ExecutionConfigAccessor;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.DeploymentOptions;
 import org.apache.flink.configuration.ExecutionOptions;
 import org.apache.flink.configuration.PipelineOptionsInternal;
 import org.apache.flink.core.execution.JobStatusChangedListener;
-import org.apache.flink.runtime.jobgraph.JobGraph;
 import org.apache.flink.streaming.api.graph.ExecutionPlan;
 import org.apache.flink.streaming.api.graph.StreamGraph;
 import org.apache.flink.streaming.runtime.execution.DefaultJobCreatedEvent;
@@ -39,7 +37,6 @@
 
 import javax.annotation.Nonnull;
 
-import java.net.MalformedURLException;
 import java.util.List;
 
 import static org.apache.flink.util.Preconditions.checkNotNull;
@@ -49,50 +46,6 @@
 public class PipelineExecutorUtils {
     private static final Logger LOG = LoggerFactory.getLogger(PipelineExecutorUtils.class);
 
-    /**
-     * Creates the {@link JobGraph} corresponding to the provided {@link Pipeline}.
-     *
-     * @param pipeline the pipeline whose job graph we are computing.
-     * @param configuration the configuration with the necessary information such as jars and
-     *     classpaths to be included, the parallelism of the job and potential savepoint settings
-     *     used to bootstrap its state.
-     * @param userClassloader the classloader which can load user classes.
-     * @return the corresponding {@link JobGraph}.
-     */
-    public static JobGraph getJobGraph(
-            @Nonnull final Pipeline pipeline,
-            @Nonnull final Configuration configuration,
-            @Nonnull ClassLoader userClassloader)
-            throws MalformedURLException {
-        checkNotNull(pipeline);
-        checkNotNull(configuration);
-
-        final ExecutionConfigAccessor executionConfigAccessor =
-                ExecutionConfigAccessor.fromConfiguration(configuration);
-        final JobGraph jobGraph =
-                FlinkPipelineTranslationUtil.getJobGraph(
-                        userClassloader,
-                        pipeline,
-                        configuration,
-                        executionConfigAccessor.getParallelism());
-
-        configuration
-                .getOptional(PipelineOptionsInternal.PIPELINE_FIXED_JOB_ID)
-                .ifPresent(strJobID -> jobGraph.setJobID(JobID.fromHexString(strJobID)));
-
-        if (configuration.get(DeploymentOptions.ATTACHED)
-                && configuration.get(DeploymentOptions.SHUTDOWN_IF_ATTACHED)) {
-            jobGraph.setInitialClientHeartbeatTimeout(
-                    configuration.get(ClientOptions.CLIENT_HEARTBEAT_TIMEOUT).toMillis());
-        }
-
-        jobGraph.addJars(executionConfigAccessor.getJars());
-        jobGraph.setClasspaths(executionConfigAccessor.getClasspaths());
-        jobGraph.setSavepointRestoreSettings(executionConfigAccessor.getSavepointRestoreSettings());
-
-        return jobGraph;
-    }
-
     /**
      * Notify the {@link DefaultJobCreatedEvent} to job status changed listeners.
      *