Set flink-conf parameters dynamicly

[Vasily Melnik]

Hi, all
I wonder is it possible to pass custom flink-conf file as run util parameter or change config parameters in Java code manually? 

I'd like to change metrics.scope parameter for each job independently. 

[Dian Fu]

Hi Vasily Melnik,

If you use yarn mode, you could try to use the option "-yD <property=value>" during submitting the job [1] to change the configuration dynamically.

[1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html

Regards,

Dian

在 2019年9月19日，下午10:13，Vasily Melnik <[hidden email]> 写道：

Hi, all
I wonder is it possible to pass custom flink-conf file as run util parameter or change config parameters in Java code manually? 

I'd like to change metrics.scope parameter for each job independently. 

[Vasily Melnik]

Thanks, Dian!
It works for me)

On Thu, 19 Sep 2019 at 18:10, Dian Fu <[hidden email]> wrote:

Hi Vasily Melnik,

If you use yarn mode, you could try to use the option "-yD <property=value>" during submitting the job [1] to change the configuration dynamically.

[1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html

Regards,

Dian

在 2019年9月19日，下午10:13，Vasily Melnik <[hidden email]> 写道：

Hi, all
I wonder is it possible to pass custom flink-conf file as run util parameter or change config parameters in Java code manually? 

I'd like to change metrics.scope parameter for each job independently.