Hi!

So you would like to submit a yarn job with Java code, not using /bin/flink
run?

If that is the case, you'll need to set 'execution.target' config option to
'yarn-per-job'. Set this in the configuration of ExecutionEnvironment and
execute the job with Flink API as normal.

Kamil ty <kamilt...@gmail.com> 于2021年12月7日周二 19:16写道:

> Hello all,
>
> I'm looking for a way to submit a Yarn job from another flink jobs
> application code. I can see that you can access a cluster and submit jobs
> with a RestClusterClient, but it seems a Yarn per-job mode is not supported
> with it.
>
> Any suggestions would be appreciated.
>
> Best Regards
> Kamil
>

Reply via email to