Do you mean in the job java code, where you call “env.execute()”? I don't think so. The yarn queue is a Flink cluster level configuration, and I don't think you can change the cluster level configurations in your job code. You job might even be created after the cluster is started, e.g., in a Flink YARN Session.[1]
Thank you~ Xintong Song [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/yarn_setup.html#flink-yarn-session On Thu, Mar 12, 2020 at 6:20 PM Vitaliy Semochkin <vitaliy...@gmail.com> wrote: > Thank you Xintong Song, > > is there any way to queue programmatically, i.e. via java code? > > Regards, > Vitaliy > > On Thu, Mar 12, 2020 at 5:56 AM Xintong Song <tonysong...@gmail.com> > wrote: > >> Hi Vitaliy, >> >> You can specify a yarn queue by either setting the configuration option >> 'yarn.application.queue' [1], or using the command line option '-qu' (or >> '--queue') [2]. >> >> Thank you~ >> >> Xintong Song >> >> >> [1] >> https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/config.html#yarn-application-queue >> [2] >> https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/yarn_setup.html#start-a-session >> >> On Thu, Mar 12, 2020 at 3:56 AM Vitaliy Semochkin <vitaliy...@gmail.com> >> wrote: >> >>> Hi, >>> >>> How can I specify a yarn queue when I start a new job programmatically? >>> >>> Regards, >>> Vitaliy >>> >>
