flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nico Kruber <n...@data-artisans.com>
Subject Re: System properties when submitting flink job to YARN Session
Date Mon, 10 Jul 2017 13:56:32 GMT
Hi Jins,
I'm not sure whether you can define a system property, but you can include it 
in the program arguments of "flink run [OPTIONS] <jar-file> <arguments>"

You may also be able to define system properties but these are probably only 
valid in your main() function executed within the flink run script, not any 
operators run on other JVM nodes. Have you tried that?


On Saturday, 8 July 2017 18:08:59 CEST Jins George wrote:
> Hello,
> I want to set the path of a properties file as System property in my
> application(something like -Dkey=value).
> Is there a way to set it while submitting a flink job to running YARN
> Session? I am using //bin/flink run/ to submit the job to a already
> running YARN session.
> Thanks,
> Jins George

View raw message