Hi Vishwas The java option is used to start jobmanager and taskmanager jvm process. It should take effect when you set is in the flink-conf.yaml on all nodes. It is a flink cluster level configuration, not a job level. So i'm not sure what do you want to do.
Best, Yang Vishwas Siravara <vsirav...@gmail.com> 于2019年8月15日周四 上午3:39写道: > Thanks a lot, I fixed that, so now this works when I submit my job with > the flink UI but when I submit it via flink run(command line) it does not > take this env.java.opts: -Dconfig.resource=qa.conf property . How can I > pass the jvm property to flink run which is running standalone without > resource manager. > > Thanks, > Vishwas > > On Wed, Aug 14, 2019 at 2:35 PM Aleksandar Mastilovic < > amastilo...@sightmachine.com> wrote: > >> It’s a YAML file, so I think you need to do something like >> >> env.java.opts: -Dconfig.resource=qa.conf >> >> On Aug 14, 2019, at 11:58 AM, Vishwas Siravara <vsirav...@gmail.com> >> wrote: >> >> When I add env.java.opts like this >> env.java.opts:"-Dconfig.resource=qa.conf" >> >> I see an error in the log file saying : - Error while trying to split >> key and value in configuration file >> /data/flink-1.7.2/conf/flink-conf.yaml:248: >> "env.java.opts:"-Dconfig.resource=qa.conf"" >> >> This is really confusing and I cant find any document on how I should >> pass this option. >> >> Thanks, >> Vishwas >> >> On Wed, Aug 14, 2019 at 12:40 PM Vishwas Siravara <vsirav...@gmail.com> >> wrote: >> >>> Is it possible for me to pass these arguments along with the job when I >>> do flink run and then pass the jvm options. For example if I want to pass >>> this parameter -Dconfig.resource=qa.conf and qa.conf is packaged in the >>> job's fat jar then flink will not find this file if I pass >>> -Dconfig.resource=qa.conf and qa.conf in env.java.opts. >>> >>> Thanks, >>> Vishwas >>> >>> On Mon, Aug 12, 2019 at 6:00 PM Zili Chen <wander4...@gmail.com> wrote: >>> >>>> Hi Vishwas, >>>> >>>> Replace ',' with ' '(space) should work. >>>> >>>> Best, >>>> tison. >>>> >>>> >>>> Vishwas Siravara <vsirav...@gmail.com> 于2019年8月13日周二 上午6:50写道: >>>> >>>>> Hi guys, >>>>> I have this entry in flink-conf.yaml file for jvm options. >>>>> env.java.opts: "-Djava.security.auth.login.config={{ >>>>> flink_installed_dir }}/kafka-jaas.conf,-Djava.security.krb5.conf={{ >>>>> flink_installed_dir }}/krb5.conf" >>>>> >>>>> Is this supposed to be a , separated list ? I get a parse exception >>>>> when the cluster starts. >>>>> >>>>> Thanks, >>>>> Vishwas >>>>> >>>> >>