You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by M Singh <ma...@yahoo.com> on 2019/06/26 13:07:47 UTC

Re: Apache Flink - How to pass configuration params in the flink-config.yaml file to local execution environment

 Hey Folks:  Just wanted to see if you have any advice on this issue of passing config parameters to the application.  I've tried passing parameters by using

ParameterTool parameterTool = ParameterTool.fromMap(config);StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.getConfig().setGlobalJobParameters(parameterTool);
But the parameters in the parameter argument are not picked up by the application.
Thanks again for your help.
Mans
    On Sunday, May 19, 2019, 02:50:03 PM EDT, M Singh <ma...@yahoo.com> wrote:  
 
 Hey Flink Folks:
I was trying to find out how can pass the params in the flink-config.yaml file to a application running in local env. 

Can I create a flink-config.yaml file and include it in the class path ? Or can I pass the parameters via the parameter tool ?
Please let me know if there is any documentation on this.

Thanks.