[
https://issues.apache.org/jira/browse/FLINK-32308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32308.
----------------------------------
Resolution: Invalid
[~SpongebobZ] This request for help should be asked via the User mailing list,
Stackoverflow or Slack. Jira is for bugs or new feature requests
> RestClusterClient submit job to remote cluster
> ----------------------------------------------
>
> Key: FLINK-32308
> URL: https://issues.apache.org/jira/browse/FLINK-32308
> Project: Flink
> Issue Type: Bug
> Components: Runtime / REST
> Affects Versions: 1.14.5
> Reporter: Spongebob
> Priority: Not a Priority
>
> I just used `RestClusterClient` submit job to remote cluster, but out of my
> expectation it submitted to local cluster instead. Could you help with me
> {code:java}
> String host = "x.x.x.x";
> int port = 8081;
> Configuration flinkConfiguration = new Configuration();
> flinkConfiguration.setString(JobManagerOptions.ADDRESS, host);
> flinkConfiguration.setInteger(JobManagerOptions.PORT, 6123);
> flinkConfiguration.setInteger(RestOptions.PORT, port);
> RestClusterClient<StandaloneClusterId> clusterClient = new
> RestClusterClient<>(flinkConfiguration, StandaloneClusterId.getInstance());
> String s = clusterClient.getWebInterfaceURL();
> List<URL> extraJars = new ArrayList<>();
> extraJars.add(new File("C:\\Users\\extend.jar").toURI().toURL());
> PackagedProgram packagedProgram = PackagedProgram.newBuilder()
> .setConfiguration(flinkConfiguration)
> .setJarFile(new File("F:\\data.jar"))
> .setEntryPointClassName("MyApplication")
> .setUserClassPaths(extraJars)
> .build();
> JobID jobID = JobID.generate();
> JobGraph jobGraph = PackagedProgramUtils.createJobGraph(packagedProgram,
> flinkConfiguration, 2, jobID, false);
> clusterClient.submitJob(jobGraph);
> System.out.println(jobID); {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
