Hi Vishwas,
I think we are on the same page now.
> When you submit a job through Flink WebUI, your main code will be
executed in the job manager jvm process. Since job manager is started with
the java opts in flink-conf.yaml, so you could find it works.
> When you submit a job in command
No this does not work , the config in flink-config.yaml applies only to job
manager and task manager for env.java.options. When I say "flink run ..."
from command line, there is a new jvm which is created which starts the
main method and that does not get the env.java.options which is set in the
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
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
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 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
Hi Vishwas,
Replace ',' with ' '(space) should work.
Best,
tison.
Vishwas Siravara 于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
>
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
