How to set global config in the rich functions

[zhen li]

Hi:

    I want to set some configs in the source functions use getRuntimeContext().getExecutionConfig().setGlobalJobParameters(parameterTool)

    And  used the configs in the downstream operators such as filter function through the getGlobalJobParameters, But it returns null pointer exception.Is the global config  only can set in the start of streams?

[Hequn Cheng]

Hi zhen,

Global configs can not be passed like this. You can set the global configs through ExecutionConfig, more details here[1]. 

[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/best_practices.html#register-the-parameters-globally

On Wed, Jul 4, 2018 at 8:27 PM, zhen li <[hidden email]> wrote:

Hi:

    I want to set some configs in the source functions use getRuntimeContext().getExecutionConfig().setGlobalJobParameters(parameterTool)

    And  used the configs in the downstream operators such as filter function through the getGlobalJobParameters, But it returns null pointer exception.Is the global config  only can set in the start of streams?